Function createQueueingEffect

effect/src/createEffect.ts:308–318

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

  // The first batch starts us listening
  batch.next();

  return Object.assign(executor, extensions);
}

/** Creates an Effect - A higher-order wrapper around a Promise-or-Observable-or-AsyncIterator returning function.
 * The effect is cancelable if it returns an Observable. `createQueueingEffect` runs in concurrency mode: "immediate" aka `mergeMap`.
 * @summary ![immediate mode](https://d2jksv3bi9fv68.cloudfront.net/rxfx/mode-immediate-sm.png) */
export function createImmediateEffect<
  Request,
  Response = void,
  TError extends Error = Error,
  TState = Response
>(