Class ZBWorker<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>

activeJobs

backoffTimeout

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<ConnectionStatusEventMap>

  Parameters

  • eventName: K
  • Optional params: ConnectionStatusEventMap[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<ConnectionStatusEventMap>

  Parameters

  • eventName: K
  • fn: EventReceiver<ConnectionStatusEventMap[K]>

  Returns void

on

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

• Type Parameters

  • K extends EventKey<ConnectionStatusEventMap>

  Parameters

  • eventName: K
  • fn: EventReceiver<ConnectionStatusEventMap[K]>

  Returns ZBWorker<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>

removeAllListeners

• removeAllListeners(): void

• Returns void