2

次のようなことをするとします。

Rx.Observable.range(1, 5).bufferWithCount(2, 1).subscribe(console.log);

これは以下を返します:

[1, 2]
[2, 3]
[3, 4]
[4, 5]
[5]

結果が次のようになることを望みます(基本的に、最初の値を強制的に出力します):

[<userDefined>, 1]
[1, 2]
[3, 4]
etc...
4

1 に答える 1

1

どうですか:

Rx.Observable.range(1, 5)
  // Note this value will get used for every subscription
  // after it is defined.
  .startWith(userDefined)
  .bufferWithCount(2, 1)
  .subscribe(console.log);
于 2016-10-17T21:34:06.573 に答える