Interface IQueueCallbacks<T, TResult>

Callbacks for ImportQueue lifecycle events.

interface IQueueCallbacks<T, TResult = IImportJobResult> {
    process: (item: T) => Promise<TResult>;
    onJobComplete: (
        item: T,
        result: Error | TResult,
    ) => Procedure<{ status: string }>;
    onQueueEmpty: () => Procedure<{ status: string }>;
}

Properties

process: (item: T) => Promise<TResult>

Processes a single queued item. Returns the result.

onJobComplete: (
item: T,
result: Error | TResult,
) => Procedure<{ status: string }>

Called after each item completes (success or failure).

onQueueEmpty: () => Procedure<{ status: string }>

Called when the queue drains completely.