# File lib/amq/client/async/adapters/event_machine.rb, line 323 def receive_data(chunk) @chunk_buffer << chunk while frame = get_next_frame self.receive_frame(AMQ::Client::Framing::String::Frame.decode(frame)) end end