私のリアクティブ プログラムを 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()
より良い解決策はありますか?