Method: Tipi::Websocket#recv_loop

Defined in:
lib/tipi/websocket.rb

#recv_loop ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/tipi/websocket.rb', line 39

def recv_loop
  if (msg = @reader.next)
    yield msg.to_s
  end

  @conn.recv_loop do |data|
    @reader << data
    while (msg = @reader.next)
      yield msg.to_s
    end
  end
end