Function cancelCurrent

effect/src/createEffect.ts:200–202

()

    state.complete();
  }

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