class Protobuf::Rpc::Connectors::EMClient

def receive_data(data)
  log_debug "[#{log_signature}] receive_data: %s" % data
  @buffer << data
  parse_response if @buffer.flushed?
end