0
計算最大的固定流的流的是直接的,例如:習慣的方法來計算的最大值
var source = Rx.Observable.from([1,3,5,7,9,2,4,6,8]).max();
然而,這僅(在這種情況下9)生成一個值。
我想生成一個迄今爲止的最大值序列,直到Observable產生一個新的最大值。所以輸出結果就像[1,3,5,7,9]。
到目前爲止,我的想法是將輸出流與最大值合併,輸入流(使用combineLatest)並比較這兩個值。然而這對我來說似乎比它應該更復雜。
沒關係:我完全忽略了RxJS中的掃描運算符。將關閉/刪除這個問題。 –
我認爲你不應該關閉這個問題,有人可能也忽略了掃描。另外,'scan'後面需要'distinctUntilChanged'來產生輸出。 –