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