Class: Userlist::Push::Strategies::Threaded

Inherits:
Object
  • Object
show all
Defined in:
lib/userlist/push/strategies/threaded.rb,
lib/userlist/push/strategies/threaded/worker.rb

Defined Under Namespace

Classes: Worker

Instance Method Summary collapse

Constructor Details

#initialize(config = {}) ⇒ Threaded

Returns a new instance of Threaded.



7
8
9
10
11
12
 
# 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

Instance Method Details

#call(*args) ⇒ Object 



14
15
16
 
# File 'lib/userlist/push/strategies/threaded.rb', line 14

def call(*args)
  queue.push(args)
end