//#region src/shims/disposer.d.ts interface AsyncDisposer extends AsyncDisposable { /** * Registers a cleanup callback. Callbacks run in reverse registration order (LIFO) when the * disposer is disposed. */ defer(fn: () => void | PromiseLike): void; /** * Tracks a disposable resource and returns it. */ use(value: T): T; /** * Runs all registered teardown in reverse registration order. Equivalent to leaving an `await * using` scope. */ dispose(): Promise; } //#endregion //#region src/lib/orchestration/task-graph.d.ts type TaskRecord = Record; type TaskValidation = { [K in keyof T]: T[K] extends ((...args: any[]) => any) ? T[K] : never; }; type TaskResult = T extends ((...args: any[]) => infer R) ? Awaited : never; type InferredTaskContext = { $result: { readonly [K in keyof T]: ReturnType extends Promise ? Promise : Promise>; }; $signal: AbortSignal; $disposer: AsyncDisposer; $race(promise: PromiseLike): Promise; }; type AllValue = { [K in keyof T]: TaskResult; }; interface AllCatchContext { failedTask: (keyof T & string) | undefined; partial: Partial>; signal: AbortSignal; } type AllCatchFn = (error: unknown, ctx: AllCatchContext) => C | Promise; interface AllOptions { catch: AllCatchFn; } interface SettledFulfilled { status: "fulfilled"; value: T; } interface SettledRejected { status: "rejected"; reason: unknown; } type SettledResult = SettledFulfilled | SettledRejected; type AllSettledResult = { [K in keyof T]: SettledResult>; }; //#endregion //#region src/lib/orchestration/flow.d.ts declare const FLOW_EXIT_BRAND: unique symbol; type FlowExit = { readonly [FLOW_EXIT_BRAND]: T; }; type ExitValue = T extends FlowExit ? V : never; type FlowExitValue = { [K in keyof T]: ExitValue>; }[keyof T]; type InferredFlowTaskContext = InferredTaskContext & { $exit(value: V): FlowExit; }; type FlowResult = FlowExitValue; //#endregion export { AllSettledResult as a, SettledRejected as c, TaskResult as d, TaskValidation as f, AllOptions as i, SettledResult as l, FlowResult as n, InferredTaskContext as o, AsyncDisposer as p, InferredFlowTaskContext as r, SettledFulfilled as s, FlowExit as t, TaskRecord as u }; //# sourceMappingURL=flow-BxKpmKTg.d.ts.map