Method: GQTP::Backend::Eventmachine::Handler#receive_data

Defined in:
lib/gqtp/backend/eventmachine.rb

#receive_data(data) ⇒ Object 



60
61
62
63
64
65
66
67
68
 
# File 'lib/gqtp/backend/eventmachine.rb', line 60

def receive_data(data)
  @buffer << data
  until @read_callbacks.empty?
    size, callback = @read_callbacks.first
    break if @buffer.bytesize < size
    @read_callbacks.shift
    consume_data(size, callback)
  end
end