Class Worker<T>

constructor

• new Worker<T>(opts?: WorkerOpts<T>): Worker<T>

• Type Parameters

  • T

  Parameters

  • opts: WorkerOpts<T> = {}

  Returns Worker<T>

buffer

handlers

Readonlyopts

addGlobalHandler

• addGlobalHandler(handler: (message: T) => void): void

• Adds a handler for all messages

  Parameters

  • handler: (message: T) => void

    Function to process all messages

  Returns void

addHandler

• addHandler(k: any, handler: (message: T) => void): void

• Adds a handler for messages with specific key

  Parameters

  • k: any

    Key to handle
  • handler: (message: T) => void

    Function to process matching messages

  Returns void

clear

• clear(): void

• Removes all pending messages from the queue

  Returns void

pause

• pause(): void

• Pauses message processing

  Returns void

push

• push(message: T): void

• Adds a message to the processing queue

  Parameters

  • message: T

    Message to process

  Returns void

removeGlobalHandler

• removeGlobalHandler(handler: (message: T) => void): void

• Removes a handler for all messages

  Parameters

  • handler: (message: T) => void

    Function to process all messages

  Returns void

removeHandler

• removeHandler(k: any, handler: (message: T) => void): void

• Removes a handler for messages with specific key

  Parameters

  • k: any

    Key to handle
  • handler: (message: T) => void

    Function to process matching messages

  Returns void

resume

• resume(): void

• Resumes message processing

  Returns void