Subjectの発火箇所と、発火後のロジックは分ける。 const rx = require('rxjs'); const op = require('rxjs/operators'); let sbj = getSubject() sbj.next(1) sbj.next(2) sbj.complete() function getSubject() { let sbj = new rx.Subject sbj.subscribe(…

iif という関数がある。 iif自体は、Observableを返却する。 let arr = [1, 2, 3, 4, 5] rx.from(arr) .pipe( op.mergeMap(v => { return rx.iif( () => v % 2 === 0, rx.of(`偶数:${v}`), rx.of(`奇数:${v}`), ) }) ) .subscribe(cl) // 奇数:1 // 偶数:2 /…