rx js отдельные испускаемые значения в различных массивах

Question

Моя служба возвращает один массив. Например: return of([1, 2, 3, 4, 5, 6]) Я подписываюсь на него и внутри .pipe () хочу разделить каждые 2 значения на другой массив. Например:

let result = {
    [1, 2],
    [3, 4],
    [5, 6]
}

Как я могу этого добиться?

Answer 1

Вы можете использовать bufferCount для создания массивов из вашего потока:

from([1, 2, 3, 4, 5, 6]).pipe(
  bufferCount(2)
).subscribe(subArray => {
  console.log(subArray); // prints: [1, 2]  [3, 4]  [5, 6]
})