Method: ActionCable::Connection::Stream#initialize

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

#initialize(event_loop, socket) ⇒ Stream

:nodoc:



12
13
14
15
16
17
18
19
20
21
22
 
# File 'actioncable/lib/action_cable/connection/stream.rb', line 12

def initialize(event_loop, socket)
  @event_loop    = event_loop
  @socket_object = socket
  @stream_send   = socket.env["stream.send"]

  @rack_hijack_io = nil
  @write_lock = Mutex.new

  @write_head = nil
  @write_buffer = Queue.new
end