私のリアクティブ プログラムを rxscala でテストするには、次のようなものを作成する必要がありますObservable
。
val numberStream: Observable[Int] = Observable.???()
どれの
- 発行番号
1
- それから待つ
1s
- 発行番号
4
- それから待つ
3s
- 発行番号
2
- それから待つ
2s
私は醜い解決策を持っていますThread
とReplaySubject
:
val subject: Subject[Int] = ReplaySubject()
val numberStream: Observable = subject
new Thread(new Runnable {
def run = {
subject.onNext(1)
Thread.sleep(1000)
subject.onNext(4)
Thread.sleep(3000)
subject.onNext(2)
Thread.sleep(2000)
}
}).start()
より良い解決策はありますか?