大飞

大飞 关注TA

挑战一切!

大飞

大飞

关注TA

挑战一切!

  •  世界的顶端
  • 混口饭吃
  • 写了333,609字

该文章投稿至Nemo社区   Android  板块 复制链接


rxjava+retrofit 在kotlin的变化

发布于 2017/07/15 16:59 1,509浏览 0回复 1,503

在java 这样写

 Subscription subscribe = observable
                    .subscribeOn(Schedulers.newThread())//请求网络在子线程中
                    .observeOn(AndroidSchedulers.mainThread())//回调在主线程中
                    .subscribe(new Subscriber<BaseRespose<T>>() {
                        @Override
                        public void onCompleted() {

                        }

                        @Override
                        public void onError(Throwable e) {


                        }

                        @Override
                        public void onNext(BaseRespose<T> baseResponseVo) {
                        }
                    });

而在kotlin 这样写

val subscribe = observable!!
                .subscribeOn(Schedulers.newThread())//请求网络在子线程中
                .observeOn(AndroidSchedulers.mainThread())//回调在主线程中
                .subscribe(
                        {
                            baseResponse ->
                            LogUtil.getInstance().e(baseResponse.toString())
                            LogUtil.getInstance().e("onNext")
                        },
                        {
                            t ->
                            LogUtil.getInstance().e(t.message.toString())
                            LogUtil.getInstance().e("onError")
                        },
                        {
                            LogUtil.getInstance().e("onComplete")
                        }

                )
本文标签
 {{tag}}
点了个评