Function runFanout

runFanout<Member, Resolved, Env>(
    opts: {
        concurrency: number;
        execute: (resolved: Resolved, member: Member) => Promise<Env>;
        members: readonly Member[];
        onExecuteError: (
            resolved: Resolved,
            member: Member,
            error: unknown,
        ) => Env;
        onResolveError: (member: Member, error: unknown) => Env;
        resolve: (member: Member) => Resolved | Promise<Resolved>;
        sleep?: (ms: number) => Promise<void>;
    },
): Promise<Env[]>
The per-command fan-out loop, generic over the selection member, the resolved per-target plan, and the inner envelope type. Mirrors the original retrieveGroup worker exactly: resolve each member (a resolve failure becomes an inner error envelope, never a throw out of the batch); run the resolved request through runWithRetry (a retryable transient drop is retried, everything else recovers to an inner error envelope). Results are returned in input (record-index) order via runBoundedPool.
Type Parameters
- Member
- Resolved
- Env
Parameters
- opts: {
      concurrency: number;
      execute: (resolved: Resolved, member: Member) => Promise<Env>;
      members: readonly Member[];
      onExecuteError: (resolved: Resolved, member: Member, error: unknown) => Env;
      onResolveError: (member: Member, error: unknown) => Env;
      resolve: (member: Member) => Resolved | Promise<Resolved>;
      sleep?: (ms: number) => Promise<void>;
  }
Returns Promise<Env[]>
- Defined in src/core/fanout.ts:180

Function runFanout

Type Parameters

Parameters

Returns Promise<Env[]>

Settings