Method: ActionCable::Connection::StreamEventLoop#attach

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

#attach(io, stream) ⇒ Object 



30
31
32
33
34
35
36
 
# File 'actioncable/lib/action_cable/connection/stream_event_loop.rb', line 30

def attach(io, stream)
  @todo << lambda do
    @map[io] = @nio.register(io, :r)
    @map[io].value = stream
  end
  wakeup
end