rxjs - 如何在 rx.js 中使用 bufferWithCount 播种第一个项目？

Question

假设您执行以下操作：

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...

Answer 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);