async def METHOD_NAME(self, mode: Mode):
    self.stop_event = self.aio_context.get_event_loop().create_future()
    params = self.connector.params
    host = params.get(DriverParams.HOST.value)
    port = params.get(DriverParams.PORT.value)
    if mode == Mode.ACTIVE:
        coroutine = self._async_connect(host, port)
    else:
        coroutine = self._async_listen(host, port)
    await coroutine