Archived
1
0
Fork 0

Revert "add waitAnyoneReply func"

This reverts commit d0c97a539a.
This commit is contained in:
yzhh 2023-01-27 15:59:02 +08:00
parent d0c97a539a
commit e15f56909c

View file

@ -94,19 +94,6 @@ class MessageSession(MessageSession):
else:
raise WaitCancelException
async def waitAnyoneReply(self, msgchain, quote=True) -> MessageSession:
ExecutionLockList.remove(self)
msgchain = MessageChain(msgchain)
send = await self.sendMessage(msgchain, quote)
flag = asyncio.Event()
MessageTaskManager.add_task(self, flag, reply=send.messageId, all_=True)
await flag.wait()
result = MessageTaskManager.get_result(self)
if result:
return result
else:
raise WaitCancelException
async def sleep(self, s):
ExecutionLockList.remove(self)
await asyncio.sleep(s)