code: def _prepare_fetch(self, request: Request, response: Response):
          '''Prepare for a fetch.
  
          Coroutine.
          '''
          self._request = request
          self._response = response
  
          yield from self._init_stream()
  
          connection_closed = self._control_connection.closed()
  
          if connection_closed:
              self._login_table.pop(self._control_connection, None)
              yield from self._control_stream.reconnect()
  
          request.address = self._control_connection.address
  
          connection_reused = not connection_closed
          self.event_dispatcher.notify(self.Event.begin_control, request, connection_reused=connection_reused)
  
          if connection_closed:
              yield from self._commander.read_welcome_message()
  
          yield from self._log_in()
  
          self._response.request = requesf _prepare_fetch(self, request: Request, response: Response):
          '''Prepare for a fetch.
  
          Coroutine.
          '''
          self._request = request
          self._response = response
  
          yield from self._init_stream()
  
          connection_closed = self._control_connection.closed()
  
          if connection_closed:
              self._login_table.pop(self._control_connection, None)
              yield from self._control_stream.reconnect()
  
          request.address = self._control_connection.address
  
          connection_reused = not connection_closed
          self.event_dispatcher.notify(self.Event.begin_control, request, connection_reused=connection_reused)
  
          if connection_closed:
              yield from self._commander.read_welcome_message()
  
          yield from self._log_in()
  
          self._response.request = request
docs: Prepare for a fetch.
  
          Coroutine.