code: def _connect(self, endpoint: str):
          
          if self._socket:
              raise RuntimeError('Cannot run multiple Servers on the same socket')
  
          context = zmq.asyncio.Context()
          self._socket = context.socket(zmq.ROUTER)
          self._socket.bind(endpoint)
  
          _log.info("Starting server, listening on endpoint {}".format(endpoint))
docs: Connect the server to an endpoint. Creates a ZMQ ROUTER socket for the given endpoint.
  
          :param endpoint: Socket endpoint, e.g. "tcp://*:1234"