Method: Userlist::Push::Strategies::Threaded#initialize

Defined in:
lib/userlist/push/strategies/threaded.rb

#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