ConcatEagerStream<T> constructor

ConcatEagerStream<T>(
  1. Iterable<Stream<T>> streams
)

Constructs a Stream which emits all events from streams. Unlike ConcatStream, all Streams inside streams are immediately subscribed to and events captured at the correct time, but emitted only after the previous Stream in streams is successfully closed.

Implementation

ConcatEagerStream(Iterable<Stream<T>> streams)
    : super(_buildController(streams).stream);