Method: Ferrum::Client::Subscriber#initialize

Defined in:
lib/ferrum/client/subscriber.rb

#initialize ⇒ Subscriber

Returns a new instance of Subscriber.



8
9
10
11
12
13
14
 
# File 'lib/ferrum/client/subscriber.rb', line 8

def initialize
  @regular = Queue.new
  @priority = Queue.new
  @on = Concurrent::Hash.new

  start
end