Observableコンストラクタ
Observable
コンストラクタ (new Observable()
) は、値を監視する関数を取って Observable を返します。
一定時間ごとに値を next で流して所定回数を流したら complete する Observable を実装します。
const { Observable } = require('rxjs');
const observable$ = new Observable((observer) => {
let count = 0;
const interval = setInterval(() => {
observer.next(count);
count++;
if (count > 3) {
clearInterval(interval);
observer.complete();
}
}, 1000);
});
observable$.subscribe((value) => console.log(value));
出力
0
1
2
3