条件付きRXJS間隔


setInterval ()を使用して、特定の間隔ごとにタスクを複数回実行しました.我々は、タスクが完了した後、間隔をクリアする必要があります.rxjs間隔関数を使用してsetinterval関数をシミュレートできます.
import { interval } from "rxjs";

// creating observable
let numbers = interval(1000);

// subscribe function returns reference to observable
let numbesubs = numbers.subscribe(x => {
  console.log("Next: ", x);
  // clearing interval when x reaches 10 value
  if (x == 10) {
    unSubscribingfunction();
  }
});

function unSubscribingfunction() {
    // clearing interval
    numbesubs.unsubscribe();
}

// Logs:
// Next: 0
// Next: 1
// Next: 2
// ..
// Next: 10