We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 259f4ad commit baea26fCopy full SHA for baea26f
src/realtime/src/realtime/_async/channel.py
@@ -525,7 +525,7 @@ def _handle_message(self, message: ServerMessage):
525
self.on_error(dict(message.payload))
526
elif isinstance(message, ReplyMessage):
527
reply_payload = message.payload
528
- if message.ref and (push := self.messages_waiting_for_ack.pop(message.ref)):
+ if message.ref and (push := self.messages_waiting_for_ack.pop(message.ref, None)):
529
if reply_payload.status == "ok":
530
push.trigger(
531
RealtimeAcknowledgementStatus.Ok, reply_payload.response
0 commit comments