2017-11-03 6 views
0

私は反応学んでいると私は、このテストクラスで遊んだ:プログラムが観測可能なタイマーを待つようにする明確な方法はありますか?

public class ObserverTest{ 
    public static void main(String[] args) { 
     Observable 
       .interval(10, SECONDS) 
       .takeUntil(Observable.timer(30, SECONDS)) 
       .subscribe(System.out::println); 
    } 
} 

私は起こるしたい何がちょうど整数30秒ごとに10秒のシーケンスをプリントアウトすることです。もちろん、プログラムはただちに実行され、ただ終了します。

タイマーが完了するまで私のプログラムを待たせる便利なRXツールがありますか?私は直接スレッドを扱う必要はありません。

+0

[takeWhile?](http://reactivex.io/documentation/operators/takewhile.html)によって行うことができます。 TakeWhile(time!= 30) – masp

+0

@masp no、それはブロッキングコールではありません –

+0

いいえ、そうではありません。あなたの質問を誤解しました。 – masp

答えて

0

これは​​を呼び出すだけではなくsubscriber

関連する問題