Class ZBWorker<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>

activeJobs

grpcClient

maxJobsToActivate

pollCount

taskType

timeout

close

• close(timeout?): Promise<null>

• Returns a promise that the worker has stopped accepting tasks and has drained all current active tasks. Will reject if you try to call it more than once.

  Parameters

  • Optional timeout: number

  Returns Promise<null>

debug

• debug(msg): void

• Parameters

  • msg: JSON

  Returns void

emit

• emit<K>(eventName, params?): void

• Type Parameters

  • K extends EventKey<{
        close: "close";
        connectionError: "connectionError";
        ready: "ready";
        unknown: "unknown";
    }>

  Parameters

  • eventName: K
  • Optional params: {
        close: "close";
        connectionError: "connectionError";
        ready: "ready";
        unknown: "unknown";
    }[K]

  Returns void

error

• error(msg): void

• Parameters

  • msg: JSON

  Returns void

log

• log(msg): void

• Parameters

  • msg: JSON

  Returns void

off

• off<K>(eventName, fn): void

• Type Parameters

  • K extends EventKey<{
        close: "close";
        connectionError: "connectionError";
        ready: "ready";
        unknown: "unknown";
    }>

  Parameters

  • eventName: K
  • fn: EventReceiver

  Returns void

on

• on<K>(eventName, fn): ZBWorker<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>

• Type Parameters

  • K extends EventKey<{
        close: "close";
        connectionError: "connectionError";
        ready: "ready";
        unknown: "unknown";
    }>

  Parameters

  • eventName: K
  • fn: EventReceiver

  Returns ZBWorker<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>

removeAllListeners

• removeAllListeners(): void

• Returns void