FlatMapStreamTransformer<T, S> class

Converts each emitted item into a new Stream using the given mapper function. The newly created Stream will be be listened to and begin emitting items downstream.

The items emitted by each of the new Streams are emitted downstream in the same order they arrive. In other words, the sequences are merged together.

Example

  new Stream.fromIterable([4, 3, 2, 1])
    .transform(new FlatMapStreamTransformer((i) =>
      new Stream.fromFuture(
        new Future.delayed(new Duration(minutes: i), () => i))
    .listen(print); // prints 1, 2, 3, 4
Inheritance

Constructors

FlatMapStreamTransformer(Stream<S> mapper(T value))

Properties

transformer StreamTransformer<T, S>
final
hashCode int
The hash code for this object. [...]
read-only, inherited
runtimeType Type
A representation of the runtime type of the object.
read-only, inherited

Methods

bind(Stream<T> stream) Stream<S>
Transforms the provided stream. [...]
override
cast<RS, RT>() StreamTransformer<RS, RT>
Provides a StreamTransformer<RS, RT> view of this stream transformer. [...]
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed. [...]
inherited
toString() String
Returns a string representation of this object.
inherited

Operators

operator ==(dynamic other) bool
The equality operator. [...]
inherited