オブザーバブルが特別に必要です。
通常、私のオブザーバブルは別のスレッドで実行されます。ただし、サブスクリプションの途中で別のスレッドをブロックする必要がある場合があります。未来の振る舞いのようなもの。
例:
val o = Observable.create(/* computation */)
.subscribeOn(Schedulers.newThread())
.observeOn(/* current thread */);
val s = o.subscribe(/* subscriber */);`
突然、さらに別のスレッドでイベントが発生し、現在のスレッドにサブスクリプションの実行を待機するよう通知しますs
。(例は、Android のonPause
.)
それ、どうやったら出来るの?s
サブスクリプションを待ち、すべての結果を取得するにはどうすればよいですか?
(科目?)