const of = Rx.Observable.of(1, 2, 3, 4, 5);

​

of

  // Observable（`of`）が通知する値（1, 2, 3, 4, 5）に対して

  // 条件判定をする関数（`v => v <= 3`）を実行して、条件に合わなかった（関数の戻り値が`false`になった）場合、

  // このメソッドを実行した Observable（`of`）の`next`通知を止め、`complete`通知をする Observable を生成する。

  .takeWhile(v => v <= 3)

  .subscribe(

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

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

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

  );

// => "next: 1"

// => "next: 2"

// => "next: 3"

// => "complete"