Async::JobSourceAsyncJobProcessorDelayed

class Delayed

Represents a processor that adds a configurable delay before processing each job. This processor is useful for rate limiting or adding artificial delays to job processing.

Definitions

def initialize(delegate, delay: 0.1)

Initialize a new delayed processor.

Signature

parameter delegate Object

The delegate object that will handle job execution.

option delay Float

The delay in seconds to add before processing each job (defaults to 0.1).

Implementation

def initialize(delegate, delay: 0.1)
	super(delegate)
	
	@delay = delay
end

def call(job)

Process a job after the configured delay.

Signature

parameter job Object

The job to be processed.

Implementation

def call(job)
	sleep(@delay)
	
	super
end