Method: Aggro::Subscriber#initialize

Defined in:
lib/aggro/subscriber.rb

#initialize(endpoint, callable = nil, &block) ⇒ Subscriber

Returns a new instance of Subscriber.



6
7
8
9
10
11
12
13
14
15
16
17
 
# File 'lib/aggro/subscriber.rb', line 6

def initialize(endpoint, callable = nil, &block)
  if callable
    @callback = callable
  elsif block_given?
    @callback = block
  else
    fail ArgumentError
  end

  @transport_sub = Aggro.transport.subscriber endpoint, method(RAW_HANDLER)
  @subscribed_topics = Set.new
end