Function cancelCurrentAndQueued

effect/src/createEffect.ts:203–205

()

  // Exposes the function to trigger the effect
  const executor = function Effect(req: Request) {
    handlings.next(
      new Observable((notify) => {
        incoming.next(req);
        requests.next(req);
        notify.complete();
      })