stream library

Classes

CompositeEventSink<T>

A composite event sink that forwards events to multiple target sinks.

ExceptionStrategy

Strategy to handle exceptions thrown by downstream sinks in a CompositeEventSink.

LineSplitterConverter

SingleValueCachingStream<T>

Extension Types

StreamWithClose

Extensions

FutureEventSinkExtension on Future<EventSink<T>>

MapNotNullStreamExtension on Stream<T>

OnEventSink on EventSink<T>

OnIterableOfStreamControllers on Iterable<StreamController<T>>

OnListOfStreamControllers on List<StreamController<T>>

OnSink on Sink<T>

OnStream on Stream<T>

OnStreamOfListOfInt on Stream<List<int>>

OnStreamOfLists on Stream<List<T>>

StreamWhereTypeExtension on Stream<T>

Exceptions / Errors

CompositeSinkException

An exception thrown when ExceptionStrategy.aggregate is used and child sinks throw exceptions.