Method: Channel#initialize

Defined in:
lib/signalfx/signalflow/channel.rb

#initialize(name, detach_cb) ⇒ Channel

Returns a new instance of Channel.



20
21
22
23
24
25
26
27
 
# File 'lib/signalfx/signalflow/channel.rb', line 20

def initialize(name, detach_cb)
  @lock = Mutex.new
  @detach_lock = Mutex.new
  @detached = false
  @name = name
  @detach_from_transport = detach_cb
  @messages = QueueWithTimeout.new
end