1
次のようにします。ここで観測可能なタイムアウト
Observable.range(1,1000)
.flatMap(i -> Observable.just(i)
.subscribeOn(Schedulers.computation()
.map(i2 -> calculate(i2))
).subscribe(System.out::println)
Iは異なるthreads.I中）（大mehod）を1〜1000の観察があり、各番号を（計算用いてマッピングされているアイテムの一部量が返されるまで、タイムアウトを設定する必要があります。
-
私は2秒のタイムアウトがあります。私が購読することが2-50のアイテムを必要としています。（少なくとも2つの項目は50項目以上の加入ではなく、しなければならない）
-
2つの項目が2秒以内に放出されていない場合は
-
はタイムアウトを再起動してください。
-
タイムアウト内に10個のアイテムが返されました。残りのコードは問題なく実行されます。
Rx Javaを使用してこれを行うにはどうすればよいですか？