эти данные в зависимости от условия, т.е. когда условие выполнится данные дальше уходят по потоку?
skipUntil
это наверное не то of([1,2], [2, 3], [4,5], [6, 3]).pipe()есть такой поток, и есть условие конечный элемент массива равен 3, если выполняется то дальше передовать накопленные данные [[1, 2], [2, 3]] [[4, 5], [6, 3]]
Тогда точно filter :)
filter же не накапливает, он или пропускает или нет
bufferWhen ещё посмотрите
Вам нужно что-то вроде scan (накопить пакет) + filter (не пропускает промежуточные результаты) Или буфер
const target = source.pipe( buffer( source.pipe( delay(0), filter(([, v]) => v === 3) ) ) )
Обсуждают сегодня