BufferCountWindowStreamTransformer<T> constructor
BufferCountWindowStreamTransformer<T> (])
Implementation
BufferCountWindowStreamTransformer(
int count,
Stream Function(T event) window, [
int startBufferEvery = 0,
ignoreEmptyWindows = true,
]) : super(
WindowStrategy.firstEventOnly,
window,
onWindowEnd: (List<T> queue) => queue,
startBufferEvery: startBufferEvery,
closeWindowWhen: (Iterable<T> queue) => queue.length == count,
ignoreEmptyWindows: ignoreEmptyWindows,
) {
if (count < 1) throw ArgumentError.value(count, 'count');
if (startBufferEvery < 0) {
throw ArgumentError.value(startBufferEvery, 'startBufferEvery');
}
}