const timer = Rx.Observable.timer(4500);

const interval = Rx.Observable.interval(1000);

​

interval

  // 引数の Observable（`timter`）が `next`通知をしたら、Observable（`interval`）の

  // `next`通知を止め、`complete`通知をする Observable を生成する。

  .takeUntil(timer)

  .subscribe(

    x => console.log(`next: ${x}`),

    error => console.error(`error: ${error}`),

    () => console.log("complete")

  );

// => "next: 0"

// => "next: 1"

// => "next: 2"

// => "next: 3"

// => "complete"