code: def rpc_request(self, frame_out, connection_adapter=None):
          
          with self.rpc.lock:
              uuid = self.rpc.register_request(frame_out.valid_responses)
              self._connection.write_frame(self.channel_id, frame_out)
              return self.rpc.get_request(
                  uuid, connection_adapter=connection_adapter
              )
docs: Perform a RPC Request.
  
          :param specification.Frame frame_out: Amqp frame.
          :rtype: dict