Class ZBWorker<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>

activeJobs

backoffTimeout

grpcClient

maxJobsToActivate

pollCount

taskType

timeout

close

• close(timeout?: number): 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

  • Optionaltimeout: number

  Returns Promise<null>

debug

• debug(msg: JSON): void

  Parameters

  • msg: JSON

  Returns void

emit

• emit<K extends EventKey<ConnectionStatusEventMap>>(
      eventName: K,
      params?: ConnectionStatusEventMap[K],
  ): void

  Type Parameters

  • K extends EventKey<ConnectionStatusEventMap>

  Parameters

  • eventName: K
  • Optionalparams: ConnectionStatusEventMap[K]

  Returns void

error

• error(msg: JSON): void

  Parameters

  • msg: JSON

  Returns void

log

• log(msg: JSON): void

  Parameters

  • msg: JSON

  Returns void

off

• off<K extends EventKey<ConnectionStatusEventMap>>(
      eventName: K,
      fn: EventReceiver<ConnectionStatusEventMap[K]>,
  ): void

  Type Parameters

  • K extends EventKey<ConnectionStatusEventMap>

  Parameters

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

  Returns void

on

• on<K extends EventKey<ConnectionStatusEventMap>>(
      eventName: K,
      fn: EventReceiver<ConnectionStatusEventMap[K]>,
  ): 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