訂閱主線程

Question

如何設置Observable的異步運算符在主線程中運行，而不是在另一個線程中運行。或者至少在我們完成後設置爲在主線程中獲得結果。

@Test 
    public void retryWhen() { 
     Scheduler scheduler = Schedulers.newThread(); 
     Single.just("single") 
       .map(word -> null) 
       .map(Object::toString) 
       .retryWhen(ot -> 
         ot.doOnNext(t -> System.out.println("Retry mechanism:" + t)) 
           .filter(t -> t instanceof NullPointerException && cont < 5) 
           .flatMap(t -> Observable.timer(100, TimeUnit.MILLISECONDS,scheduler)) 
           .doOnNext(t -> cont++) 
           .switchIfEmpty(Observable.error(new NullPointerException()))) 
       .subscribeOn(scheduler) 
       .subscribe(System.out::println, System.out::println); 
//  new TestSubscriber() 
//    .awaitTerminalEvent(1000, TimeUnit.MILLISECONDS); 
    } 

我正在嘗試observerOn和subscribeOn，但都用於設置您想要執行的線程。但在我的情況下，我希望執行或結束它在我運行測試的同一線程中

現在，查看打印的唯一方法就是阻止並等待執行。

問候。

Answer 1

您可以使用Observable.toBlocking()來獲得BlockingObservable並使用它在測試中提取結果。

Answer 2

如果不指定observeOn/subscribeOn並沒有操作員或觀察的變化線程，那麼當你subscribe以可觀察到的，也可以完成訂閱在所有的處理。