BufferCountWindowStreamTransformer<T> constructor

BufferCountWindowStreamTransformer<T>(
  1. int count,
  2. Stream window(
    1. T event
    ), [
  3. int startBufferEvery = 0,
  4. dynamic ignoreEmptyWindows = true,
])

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');
  }
}