Method: ActionCable::Connection::StreamEventLoop#initialize

Defined in:
lib/action_cable/connection/stream_event_loop.rb

#initialize ⇒ StreamEventLoop

Returns a new instance of StreamEventLoop.



10
11
12
13
14
15
16
17
 
# File 'lib/action_cable/connection/stream_event_loop.rb', line 10

def initialize
  @nio = @executor = @thread = nil
  @map = {}
  @stopping = false
  @todo = Queue.new

  @spawn_mutex = Mutex.new
end