ObservableStoreExtension<S> extension

Methods

addObservable<T>(Observable<T> observable, {S next(S state, T value)?, S error(S state, Object error, StackTrace stackTrace)?, S complete(S state)?, bool ignoreErrors = false}) → Disposable

Adds an observable that asynchronously contributes to the state through next, error and complete reducers. These functions receive the current state and the events of the Observer to produce a new state.