BackpressureStreamTransformer<S, T> constructor

BackpressureStreamTransformer<S, T>(
  1. WindowStrategy strategy,
  2. Stream windowStreamFactory(
    1. S event
    )?, {
  3. T onWindowStart(
    1. S event
    )?,
  4. T onWindowEnd(
    1. List<S> queue
    )?,
  5. int startBufferEvery = 0,
  6. bool closeWindowWhen(
    1. List<S> queue
    )?,
  7. bool ignoreEmptyWindows = true,
  8. bool dispatchOnClose = true,
  9. int? maxLengthQueue,
})

Constructs a StreamTransformer which buffers events emitted by the Stream that is created by windowStreamFactory.

Use the various optional parameters to precisely determine how and when this buffer should be created.

For more info on the parameters, see BackpressureStreamTransformer, or see the various back pressure StreamTransformers for examples.

Implementation

BackpressureStreamTransformer(
  this.strategy,
  this.windowStreamFactory, {
  this.onWindowStart,
  this.onWindowEnd,
  this.startBufferEvery = 0,
  this.closeWindowWhen,
  this.ignoreEmptyWindows = true,
  this.dispatchOnClose = true,
  this.maxLengthQueue,
});