RxJS scanとreduce

sample1.ts

import * as Rx from "@reactivex/rxjs";

// scan
// 都度nextコールバックが呼ばれる
Rx.Observable.of(1, 2, 3)
	.scan((acc, value, index) => acc + value)
	.subscribe(
		value => console.log(`next: (value: ${value})`),
		error => console.log(`error: ${error}`),
		() => console.log(`complete:`));
// 実行結果
/*
next: (value: 1)
next: (value: 3)
next: (value: 6)
complete:
*/

// reduce
// completeする前に1回だけnextコールバックが呼ばれる
Rx.Observable.of(1, 2, 3)
	.reduce((acc, value, index) => acc + value)
	.subscribe(
		value => console.log(`next: (value: ${value})`),
		error => console.log(`error: ${error}`),
		() => console.log(`complete:`));
// 実行結果
/*
next: (value: 6)
complete:
*/

sample2.ts

import * as Rx from "@reactivex/rxjs";

// scan
// completeしなくてもnextコールバックが呼ばれる
Rx.Observable.create(observer => {
	observer.next(1);
	observer.next(2);
	observer.next(3);
	// completeしない
	//observer.complete();
})
	.scan((acc, value, index) => acc + value)
	.subscribe(
		value => console.log(`next: (value: ${value})`),
		error => console.log(`error: ${error}`),
		() => console.log(`complete:`));
// 実行結果
/*
next: (value: 1)
next: (value: 3)
next: (value: 6)
*/

// reduce
// completeしない限りnextコールバックが呼ばれない
Rx.Observable.create(observer => {
	observer.next(1);
	observer.next(2);
	observer.next(3);
	// completeしない
	//observer.complete();
})
	.reduce((acc, value, index) => acc + value)
	.subscribe(
		value => console.log(`next: (value: ${value})`),
		error => console.log(`error: ${error}`),
		() => console.log(`complete:`));
// 実行結果（何も表示されない）
/*
*/