RXJS 시간의 operator 요약 정보

전제 조건

timer

//１秒後にemitされるobservableを作成
const source = timer(1000);
source.subscrive((val) => console.log(val));

0;

interval

//1秒ごとにemitされるobservableを作成
const source = interval(1000);
source.subscribe((val) => console.log(val));

//unsubscribeするまで無限にemitされる
0,1,2,3,4,5,6.....

auditTime

//１秒たつと出力さ荒れるobsservable
const source = interval(1000);
//5秒間まつ。最後にemitされた値を出力する
const example = source.pipe(auditTime(5000));
const subscribe = example.subscribe((val) => console.log(val));

4...9...14

debounceTime

//１秒たつと出力さ荒れるobsservable
const source = interval(1000);
//5秒間まつ。最後にemitされた値を出力する
const example = source.pipe(debounceTime(5000));
const subscribe = example.subscribe((val) => console.log(val));

//intervalで５秒たった後に、さらに5秒待って出力される
4...9...14

throttleTime

//１秒たつと出力さ荒れるobsservable
const source = interval(1000);
//5秒間まつ。最後にemitされた値を出力する
const example = source.pipe(throttleTime(5000));
const subscribe = example.subscribe((val) => console.log(val));

 0...6...12

bufferTime

//0.5秒に一回emitされるobservable
const source = interval(500);
//１秒までに出された値を配列で返すようにする
const subscription = source.pipe(bufferTime(1000));
subscription.subscribe((val) => console.log(val));

[0,1], [2,3], [4,5]....

delay

const example = of(null);

//格observableにdelayをつけてタイミングを遅らせる
const message = merge(
	example.pipe(mapTo("Hello")),
	example.pipe(mapTo("World!"), delay(1000)),
	example.pipe(mapTo("Goodbye"), delay(2000)),
	example.pipe(mapTo("World!"), delay(3000))
);
const subscribe = message.subscribe((val) => console.log(val));

 'Hello'...'World!'...'Goodbye'...'World!'

timeout

//５秒後に値がemitされる
const time = time(5000);
//１秒で値が出されなかったらerrorをだす
const source = time.pipe(timeout(1000));
source.subscribe((catchError) => console.log("error"));

"error";