javascript - Rxjs:使用 bufferCount 时如何获取最后一个值

Question

当缓冲区大小未达到 x 时，是否有任何方法可以在使用 bufferCount(x) 时获取最新发出的值。

示例:下面的代码仅打印 [0, 1]。我希望输出在某种条件之后包含 [2] 。

const subject = new Subject();

subject.asObservable()
  .pipe(bufferCount(2))
  .subscribe(console.log);

for(let i = 0; i < 3; i++) subject.next(i);

Answer 1

您需要完成内部可观察，如下所示:

subject.complete();

然后 [2] 将按预期发出。