applyReducer method

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

Implementation

@override
Stream<Accumulator> applyReducer(Stream<Accumulator> input) {
  return input.map<Accumulator>((accumulator) {
    dynamic moduleState = accumulator.state.byName(moduleName);
    dynamic privateModuleState = accumulator.state.byName('_$moduleName');
    if (moduleState is S) {
      accumulator.state.update(moduleName, reducer(accumulator.action, moduleState, privateModuleState));
    }
    if (privateModuleState is T) {
//        if (!(accumulator.action is ReduxPrivateAction && accumulator.action.packageName != moduleName)) {
      accumulator.state.update('_$moduleName', privateReducer(accumulator.action, moduleState, privateModuleState));
//        }
    }
    return accumulator.copyWith(accumulator.state);
  });
}