class Protobuf::Rpc::Connectors::EMClient

def receive_data(data)
  log_debug { sign_message("receive_data: #{data}") }
  @response_buffer << data
  @response_data = @response_buffer.data
  parse_response if !@response_data.nil? && @response_buffer.flushed?
end