Function createImmediateEffect

effect/src/createEffect.ts:293–303

(
  handler: EffectSource<Request, Response>,
  initialState?: TState
)

        tap(fns.complete ? fns.complete : noop)(completions),
        tap(fns.canceled ? fns.canceled : noop)(cancelations),
        tap(fns.error ? fns.error : noop)(errors),
      ];
      const allEvents = merge(...streams).pipe(
        tap({
          finalize: fns.finalized,
        })
      );
      const sub = allEvents.subscribe();
      sub.add(ends.pipe(tap(fns.finalized ?? noop)).subscribe());

      return sub;
    },
  };