Interface IJobWorkerConnector<T, U>

The Job Worker Connector interface.

interface IJobWorkerConnector<T, U> {
processJob(parameters: T, options?: IJobWorkerOptions): Promise<U>;
processJobStream(parameters: T, options?: IJobWorkerOptions): AsyncGenerator<U, any, unknown>;
}

Type Parameters

T extends IJobParameters
U extends IJobResult

Hierarchy (view full)

IJobWorkerConnector
- IGenerativeAIWorkerConnector

Index

Methods

processJob processJobStream

Methods

processJob

processJob(parameters, options?): Promise<U>
Process a job.
Parameters
- parameters: T
  The job parameters.
- Optionaloptions: IJobWorkerOptions
  The job options.
Returns Promise<U>
A promise that resolves with the job result.

processJobStream

processJobStream(parameters, options?): AsyncGenerator<U, any, unknown>
Process a job stream.
Parameters
- parameters: T
  The job parameters.
- Optionaloptions: IJobWorkerOptions
  The job options.
Returns AsyncGenerator<U, any, unknown>
An async generator that yields job results.