你的位置:首页 > 软件开发 > 操作系统 > RxJava 和 RxAndroid 五(线程调度)

RxJava 和 RxAndroid 五(线程调度)

发布时间:2016-06-29 18:00:05
本文将有几个例子说明,rxjava线程调度的正确使用姿势。例1 Observable .create(new Observable.OnSubscribe<String>() { @Override public vo ...

本文将有几个例子说明,rxjava线程调度的正确使用姿势。

例1

 Observable        .create(new Observable.OnSubscribe<String>() {          @Override          public void call(Subscriber<? super String> subscriber) {            Logger.v( "rx_call" , Thread.currentThread().getName() );            subscriber.onNext( "dd");            subscriber.onCompleted();          }        })        .map(new Func1<String, String >() {          @Override          public String call(String s) {            Logger.v( "rx_map" , Thread.currentThread().getName() );            return s + "88";          }        })        .subscribe(new Action1<String>() {          @Override          public void call(String s) {            Logger.v( "rx_subscribe" , Thread.currentThread().getName() );          }        }) ;

原标题:RxJava 和 RxAndroid 五(线程调度)

关键词:JAVA

*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。