StreamStoreExtension<S> extension

on

• Store<S>

Methods

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.