Rxjs: как получить последние значения при использовании bufferCount

Question

Есть ли способ получить последние значения при использовании bufferCount(x), когда размер буфера не достигает 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] будет излучено, как и ожидалось.