INNER CODE UNIT · TypeScript

subscribe

enisdenjo/graphql-sse · src/client.ts:481

  function subscribe(
    request: RequestParams,
    sink: Sink,
    on?: EventListeners<false>,
  ) {
    if (!singleConnection) {
      // distinct connections mode

      const control = new AbortControllerImpl();
      const unlisten = client.onDispose(() => {
        unlisten();
        control.abort();
      });

      (async () => {
        let retryingErr = null as unknown,
          retries = 0;

View source record →