Observable コンストラクタ

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

参考