Function setupBlocking

packages/router/src/operators/setup_and_run_resources.ts:174–232

(
  route: ActivatedRoute,
  resourceResult: ResourceResult,
  blockingResourcePromises: Array<Promise<void>>,
  abortSignal: AbortSignal,
)

}

function setupBlocking(
  route: ActivatedRoute,
  resourceResult: ResourceResult,
  blockingResourcePromises: Array<Promise<void>>,
  abortSignal: AbortSignal,
) {
  if (abortSignal.aborted) return;
  const childInjector = route._localInjector;
  if (!childInjector || !resourceResult) return;

  for (const r of Object.values(resourceResult)) {
    const res = r as InternalRouterResource;
    if (res[BLOCKING_SYMBOL] === false) {
      continue;
    }
    const promise = new Promise<void>((resolve, reject) => {
      const underlyingRes = res[SOURCE_RESOURCE_SYMBOL];
      let isDestroyed = false;
      let unregisterOnDestroy: (() => void) | undefined;

      const cleanup = () => {
        isDestroyed = true;
        blockingEffect.destroy();
        unregisterOnDestroy?.();
        abortSignal.removeEventListener('abort', onAbort);
      };

      const onAbort = () => {
        cleanup();
        resolve();
      };

      abortSignal.addEventListener('abort', onAbort, {once: true});

      const blockingEffect = effect(
        () => {
          if (isDestroyed) {
            return;
          }
          const status = underlyingRes.status();
          if (status === 'error') {
            cleanup();
            reject(underlyingRes.error());
          } else if (hasValueOrResolved(underlyingRes)) {
            cleanup();
            resolve();
          }
        },
        {injector: childInjector, manualCleanup: true},
      );

      unregisterOnDestroy = childInjector.get(DestroyRef).onDestroy(() => {
        cleanup();
        resolve();
      });
    });
    blockingResourcePromises.push(promise);
  }