RaceStream<T> constructor

RaceStream<T>(Iterable<Stream<T>> streams)

Constructs a Stream which emits all events from a single Stream inside streams. The selected Stream is the first one which emits an event. After this event, all other Streams in streams are discarded.

Implementation

RaceStream(Iterable<Stream<T>> streams)
    : _controller = _buildController(streams);