FlatMapStreamTransformer<S, T> constructor

FlatMapStreamTransformer<S, T>(
  1. Stream<T> mapper(
    1. S value
    ), {
  2. int? maxConcurrent,
})

Constructs a StreamTransformer which emits events from the source Stream using the given mapper. The mapped Stream will be listened to and begin emitting items downstream.

Implementation

FlatMapStreamTransformer(this.mapper, {this.maxConcurrent});