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