code: def connect(self, (host, port)):
          '''
          Connect assuming a host and port tuple. Implemented as non-blocking,
          and will close the transport if there's an error
          '''
          self._host = "%s:%s" % (host, port)
          self._sock = EventSocket(
              read_cb=self._sock_read_cb,
              close_cb=self._sock_close_cb,
              error_cb=self._sock_error_cb,
              debug=self.connection.debug,
              logger=self.connection.logger)
          if self.connection._sock_opts:
              for k, v in self.connection._sock_opts.iteritems():
                  family, type = k
                  self._sock.setsockopt(family, type, v)
          self._sock.setblocking(False)
          self._sock.connect(
              (host, port), timeout=self.connection._connect_timeout)
          self._heartbeat_timeout = Nonf connect(self, (host, port)):
          '''
          Connect assuming a host and port tuple. Implemented as non-blocking,
          and will close the transport if there's an error
          '''
          self._host = "%s:%s" % (host, port)
          self._sock = EventSocket(
              read_cb=self._sock_read_cb,
              close_cb=self._sock_close_cb,
              error_cb=self._sock_error_cb,
              debug=self.connection.debug,
              logger=self.connection.logger)
          if self.connection._sock_opts:
              for k, v in self.connection._sock_opts.iteritems():
                  family, type = k
                  self._sock.setsockopt(family, type, v)
          self._sock.setblocking(False)
          self._sock.connect(
              (host, port), timeout=self.connection._connect_timeout)
          self._heartbeat_timeout = None
docs: Connect assuming a host and port tuple. Implemented as non-blocking,
          and will close the transport if there's an error