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