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ツールがありますか?私は直接スレッドを扱う必要はありません。
[takeWhile?](http://reactivex.io/documentation/operators/takewhile.html)によって行うことができます。 TakeWhile(time!= 30) – masp
@masp no、それはブロッキングコールではありません –
いいえ、そうではありません。あなたの質問を誤解しました。 – masp