RxJava には Observable.toBlocking() 演算子があり、オブザーバブルのデータを同期的に取得します。RxJS の同様の演算子が見つかりません。この演算子を使用して、別の関数型プログラミング ライブラリを使用せずに、Rx を使用してコードを改善したいと考えています...
1353 次
1 に答える
2
スケジューラを見る
スケジューラーを提供しない場合、RxJS は最小並行性の原則を使用してデフォルトのスケジューラーを選択します。これは、オペレーターのニーズを満たす最小量の並行性を導入するスケジューラーが選択されることを意味します。
スケジューラを指定しない限り、このjsbinでわかるように、RxJS 自体がブロッキング スケジューラを選択し、オブザーバブルを同期的に解決します (即時スケジューラ) 。最初のオブザーバブルは、2 番目のオブザーバブルが開始される前に完了します。
並行性のレベルを明示的に制御したい場合は、このオプションをサポートするオペレーターに特定のスケジューラーを渡すことでこれを行うことができます。
于 2015-12-17T18:15:18.593 に答える