Actions and updates

This commit is contained in:
Will McGugan
2021-06-14 16:35:14 +01:00
parent 223636d68e
commit 8c63c6cb0e
6 changed files with 106 additions and 19 deletions

View File

@@ -153,7 +153,7 @@ class MessagePump:
pending = self.peek_message()
if pending is None or not message.can_batch(pending.message):
break
priority, message = pending
priority, message = await self.get_message()
try:
await self.dispatch_message(message, priority)