Future addStream(
Stream<S> stream
)

Consumes the elements of stream.

Listens on stream and does something for each event.

The consumer may stop listening after an error, or it may consume all the errors and only stop at a done event.

Source

/**
 * Consumes the elements of [stream].
 *
 * Listens on [stream] and does something for each event.
 *
 * The consumer may stop listening after an error, or it may consume
 * all the errors and only stop at a done event.
 */
Future addStream(Stream<S> stream);