code: def connect(self, address, **kwargs):
          
          if self._transport:
              raise RuntimeError('already connected')
          kwargs.setdefault('timeout', self._timeout)
          conn = create_connection(self._protocol_factory, address, **kwargs)
          self._transport = conn[0]
          self._transport._log = self._log
          self._protocol = conn[1]
          self._protocol._log = self._log
docs: Connect to *address* and wait for the connection to be established.
  
          See :func:`~gruvi.create_connection` for a description of *address*
          and the supported keyword arguments.