BufferCountWindowExtensions<T> extension

on

Methods

bufferCountTimeout(int count, Duration timeout, {dynamic ignoreEmptyWindows = true}) → Stream<List<T>>: Buffers the stream and emits the buffer when EITHER: a) the number of elements reaches count, OR b) a periodic timeout occurs
bufferCountWindow(int count, Stream window, {dynamic ignoreEmptyWindows = true}) → Stream<List<T>>: Buffers the stream and emits the buffer when EITHER: a) the number of elements reaches count, OR b) the window Stream emits