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

​

observable

  // `scan`を実行した Observable（`observable`）が`next`通知する値（`1`、`2`、`3`、`4`、`5`）に対して

  // 累積した値と通知された値を加算する関数（`(accumulator, value) => accumulator + value`）を実行し、その戻り値を累積して通知する。

  // `accumulator` に累積された値が渡され（初期値が第２引数である`0`）、`value`に通知された値が渡される。

  // そのため、今回の関数の場合、以下のように値を加算して累積する

  // 1回目の`next`通知では`accumulator`が`0`で`value`が`1`なので、`0 + 1`の戻り値である`1`を累積して`next`通知する

  // 2回目の`next`通知では`accumulator`が`1`で`value`が`2`なので、`1 + 2`の戻り値である`3`累積して`next`通知する

  // 3回目の`next`通知では`accumulator`が`3`で`value`が`3`なので、`3 + 3`の戻り値である`6`累積して`next`通知する

  // 4回目の`next`通知では`accumulator`が`6`で`value`が`4`なので、`6 + 4`の戻り値である`10`累積して`next`通知する

  // 5回目の`next`通知では`accumulator`が`10`で`value`が`5`なので、`10 + 5`の戻り値である`15`累積して`next`通知する

  .scan((accumulator, value) => accumulator + value, 0)

  .subscribe(

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

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

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

  );

// => "next: 1"

// => "next: 3"

// => "next: 6"

// => "next: 10"

// => "next: 15"

// => "complete"