WithLatestFromStreamTransformer<S, T, R> constructor

WithLatestFromStreamTransformer<S, T, R>(
  1. Iterable<Stream<T>> latestFromStreams,
  2. R combiner(
    1. S t,
    2. List<T> values
    )
)

Constructs a StreamTransformer that emits when the source Stream emits, combining the latest values from latestFromStreams using the provided function fn.

Implementation

WithLatestFromStreamTransformer(this.latestFromStreams, this.combiner);