ループはfromで置き換える。 ループはもう使わなくていいでしょ。 非同期通信じゃなくても、RxJS使っていく方向でいいんじゃないか。 と思ったりもする。 let arr = [1, 2, 3, 4, 5] rx.from(arr) .subscribe(cl)

if文はfilterオペレータに置き換えることが出来る。 rx.of(0, 1, 2, 3, 4) .pipe( op.filter(v => v % 2 === 0) ) .subscribe(cl) // 0, 2, 4 と表示

ストリームと関係のない処理は、積極的にtapを使いたい。 パッと見で「副作用のある処理」が分かるようになる。見やすい。 let foo = rx.interval(1000).pipe(op.take(1)) foo.pipe( op.tap(cl) // 0と表示 ) .subscribe(cl) // 0と表示 function cl(v) { co…

Promise.all()。 すべてのPromiseが発火されるのを待つ。 let foo1 = getPromise(123) let foo2 = getPromise('abc') Promise.all([foo1, foo2]) .then(cl) // [123, 'abc'] forkJoinで書き換えられる。 let bar1 = rx.interval(100).pipe(op.take(1)) let b…