RxJava計劃對主線程

觀察如果我寫了這樣的事情，然後都操作和通知將在當前線程...RxJava計劃對主線程

Observable.fromCallable(() -> "Do Something") 
    .subscribe(System.out::println);

如果我做一個操作像這樣的後臺線程，然後都操作和通知將在背景線程...

Observable.fromCallable(() -> "Do Something") 
    .subscribeOn(Schedulers.io()) 
    .subscribe(System.out::println);

如果我想觀察在主線程和做後臺的Android我會做...

Observable.fromCallable(() -> "Do Something") 
    .subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(System.out::println);

但如果我寫一個標準的Java程序，什麼是聲明，相當於你想要觀察主線程？

來源

2017-06-20 Eurig Jones

你需要一個阻塞調度此作爲Java的主線程是不是一個游泳池/尺蠖。這僅適用於擴展項目中的RxJava 2.x：https：//github.com/akarnokd/RxJava2Extensions#blockingscheduler – akarnokd

通過.toBlocking()將Observable轉換爲BlockingObservable;這給你堵的方法來等待完成，拿到一個項目，等

來源

2017-06-20 17:41:05

對於RxJava2使用「blockingSubscribe()」

Flowable.fromArray(1, 2, 3) 
       .subscribeOn(Schedulers.computation()) 
       .blockingSubscribe(integer -> { 
        System.out.println(Thread.currentThread().getName()); 
       });

來源

2017-10-27 10:22:35 Dmitry

RxJava計劃對主線程

回答

相關問題