applyReducer method

  1. @override
Stream<Accumulator<S>> applyReducer(
  1. Stream<Accumulator<S>> input
)
override

Implementation

@override
Stream<Accumulator<S>> applyReducer(Stream<Accumulator<S>> input) {
  return input.map<Accumulator<S>>((accumulator) {
    return accumulator
        .copyWith(reducer(accumulator.state, accumulator.action));
  });
}