class Userlist::Push::Strategies::Threaded
Attributes
queue[R]
worker[R]
Public Class Methods
new(config = {})
click to toggle source
# File lib/userlist/push/strategies/threaded.rb, line 7 def initialize(config = {}) @queue = Queue.new @worker = Worker.new(queue, config) at_exit { stop_worker } end
Public Instance Methods
call(*args)
click to toggle source
# File lib/userlist/push/strategies/threaded.rb, line 14 def call(*args) queue.push(args) end
Private Instance Methods
stop_worker()
click to toggle source
# File lib/userlist/push/strategies/threaded.rb, line 22 def stop_worker worker&.stop end