Skip to content

Commit 7e3b81a

Browse files
authored
fix(realtime): cancel timeout task if a successful response arrives (#1300)
1 parent 60f07a8 commit 7e3b81a

File tree

1 file changed

+2
-0
lines changed
  • src/realtime/src/realtime/_async

1 file changed

+2
-0
lines changed

src/realtime/src/realtime/_async/push.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,9 +135,11 @@ def trigger(
135135
def trigger(self, status: RealtimeAcknowledgementStatus, response) -> None:
136136
self.received_resp = (status, response)
137137
if status == RealtimeAcknowledgementStatus.Ok:
138+
self._cancel_timeout()
138139
for ok_callback in self.ok_callbacks:
139140
ok_callback(response)
140141
elif status == RealtimeAcknowledgementStatus.Error:
142+
self._cancel_timeout()
141143
for error_callback in self.error_callbacks:
142144
error_callback(response)
143145
elif status == RealtimeAcknowledgementStatus.Timeout:

0 commit comments

Comments
 (0)