class Protobuf::Rpc::Connectors::EventMachine

def error_stop_reactor(message)
  err = Protobuf::Rpc::ClientError.new(Protobuf::Socketrpc::ErrorReason::RPC_ERROR, message)
  ensure_cb.call(err)
  ::EM.stop unless @using_global_reactor
end