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