forkJoin はcomplete()を感知する。 let sub1 = new rx.Subject let sub2 = new rx.Subject rx.forkJoin(sub1, sub2) .subscribe(cl) sub1.next(1) sub1.complete() sub2.next(2) sub2.complete() // [1, 2] sub1.next(1) sub2.next(2) // 表示なし concat …

error が発生したら、後続のストリームは無視される。 obs(123) .subscribe(cl_next, cl_error, cl_complete); // next:123 // error:123 共通関数。 function obs(v = 0) { return rx.Observable.create((observer) => { setTimeout(() => { observer.next(…