SideEffect<A, S> typedef

SideEffect<A, S> = Stream<A> Function(Stream<A> actions, GetState<S> getState)

It is a function which takes a stream of actions and returns a stream of actions. Actions in, actions out (concept borrowed from redux-observable.js.or - so called epics).

  • Param actions: Stream<A> input action. Every SideEffect should be responsible to handle a single Action (i.e using where or whereType operator from rxdart package)
  • Param state: GetState<S> to get the latest state of the state machine

Implementation

typedef SideEffect<A, S> = Stream<A> Function(
  Stream<A> actions,
  GetState<S> getState,
);