def __init__(
self,
REMOTE_IP,
REMOTE_PORT,
loop: asyncio.AbstractEventLoop() = None,
executor: futures.Executor() = None
):
self._input_list = []
self._input_queue = asyncio.Queue()
if loop:
self.loop = loop
else:
self.loop = asyncio.get_event_loop()
self.executor = executor
self.REMOTE_IP = REMOTE_IP
self.REMOTE_PORT = REMOTE_PORT
评论列表
文章目录