WithLatestFromStreamTransformer<T, S, R> constructor

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

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

Implementation

WithLatestFromStreamTransformer(
    Iterable<Stream<S>> latestFromStreams, R Function(T t, List<S> values) fn)
    : _transformer = _buildTransformer(latestFromStreams, fn);