Class TakaroWorker<T>Abstract

constructor

• new TakaroWorker<T>(
      name: string,
      concurrency?: number,
      fn: Processor<T, unknown>,
      extraBullOpts?: WorkerOptionsWithoutConnectionOptions,
  ): TakaroWorker<T>

• Type Parameters

  • T

  Parameters

  • name: string
  • concurrency: number = 1
  • fn: Processor<T, unknown>
  • extraBullOpts: WorkerOptionsWithoutConnectionOptions = {}

  Returns TakaroWorker<T>

bullWorker

log