StreamStoreExtension<S> extension



addStream<T>(Stream<T> stream, {S onData(S state, T event)?, S onError(S state, Object error, StackTrace stackTrace)?, S onDone(S state)?, bool? cancelOnError}) StreamSubscription<T>
Adds a stream that asynchronously contributes to the state through onData, onError and onDone reducers. These functions receive the current state and the events of the Stream to produce a new state.