downflux / TaskCoordinator
Defined in: packages/core/coordinators/TaskCoordinator.ts:16
Coordinates concurrent work within an execution result.
The task coordinator owns concurrency, hooks, progress updates, and output mode behavior. It keeps download scheduling separate from provider methods and from the lower-level transfer code that writes individual items.
new TaskCoordinator(
transferCoordinator,fileManager,transformerRegistry,progressManager,pipelineRegistry):TaskCoordinator
Defined in: packages/core/coordinators/TaskCoordinator.ts:19
TaskCoordinator
runWithConcurrency<
T>(items,concurrency,worker):Promise<void>
Defined in: packages/core/coordinators/TaskCoordinator.ts:142
Runs asynchronous workers with a bounded concurrency limit.
T
T[]
Items to process.
number
Maximum number of active workers.
(item, index) => Promise<void>
Async item handler.
Promise<void>
handleJsonOutput<
T,S>(result,options):Promise<ExecutionResult<T,S>>
Defined in: packages/core/coordinators/TaskCoordinator.ts:166
Persists a JSON execution result.
T
S extends ExecutionShape
ExecutionResult<T, S>
Execution result to serialize.
Output options containing directory configuration.
Promise<ExecutionResult<T, S>>
The original execution result.
handleDeviceOutputAsync<
T,S>(options,outputType,request,pipelineHooks,result):void
Defined in: packages/core/coordinators/TaskCoordinator.ts:183
Starts background download processing for device or buffer output.
T
S extends ExecutionShape
Execution options.
Output mode.
Original execution request.
Hooks fired around extraction/download events.
ExecutionResult<T, S>
Execution result to update while downloads progress.
void