Function singleRequestHandler

effect/src/createEffect.ts:81–110

(request: Request)

  const actualHandler =
    options?.timeout
      ? timeoutHandler<Request, Response, TError>(options.timeout, handler)
      : handler;
  const errors = new Subject<TError>();

  const currentError = new BehaviorSubject<TError | null>(null);
  const lastResponse = new BehaviorSubject<Response | null>(null);
  // seed `state` with initialState or null
  const state = new BehaviorSubject<TState | null>(initialState ?? null);

  const incoming = new Subject<Request>();
  const requests = new Subject<Request>();
  const responses = new Subject<Response>();
  const starts = new Subject<Request>();
  const ends = new Subject<Request>();
  const completions = new Subject<Request>();
  const cancelations = new Subject<Request>();

  const currentCancel = new Subject<void>();
  const batch = new Subject<void>();
  const handlings = new Subject<Observable<void>>();
  const isHandling = new BehaviorSubject<boolean>(false);
  const isActive = new BehaviorSubject<boolean>(false);

  const singleRequestHandler = (request: Request) => {
    let oneResult: any = [];

    currentError.next(null);

    try {
      oneResult = actualHandler(request);
    } catch (e) {
      errors.next(e as TError);
    }