Function reduceWith

effect/src/createEffect.ts:235–262

(
      reducer: (
        state: TState,
        evt: LifecycleReducerEvent<Request, Response, Error>
      ) => TState,
      initial: TState
    )

      batch.next();
      if (_reducer) {
        stateSub.unsubscribe();
        // @ts-expect-error
        this.reduceWith(_reducer, initialState);
      }
      // @ts-expect-error
      state.next(initialState);
    },
    shutdown: shutdownSelf,
    // Events
    requests: incoming.asObservable(),
    errors: errors.asObservable(),
    responses: responses.asObservable(),
    starts: starts.asObservable(),
    completions: completions.asObservable(),
    cancelations: cancelations.asObservable(),

    // Stateful
    lastResponse,
    currentError,
    isHandling,
    isActive,
    state,

    reduceWith(
      reducer: (
        state: TState,
        evt: LifecycleReducerEvent<Request, Response, Error>
      ) => TState,
      initial: TState
    ) {
      _reducer = reducer; // save to resubscribe after reset