RxJS complete()

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 も、complete()しないと直列で次のObservableに移っていかない。

let sub1 = new rx.Subject
let sub2 = new rx.Subject

rx.concat(sub1, sub2)
.subscribe(cl)

sub1.next(1)
sub1.complete()
sub2.next(2)
sub2.complete()
// 1
// 2

sub1.next(1)
sub2.next(2)
// 1