diff --git a/src/realtime/src/realtime/_async/push.py b/src/realtime/src/realtime/_async/push.py
index 84be1b8e..d252f0c9 100644
--- a/src/realtime/src/realtime/_async/push.py
+++ b/src/realtime/src/realtime/_async/push.py
@@ -135,9 +135,11 @@ def trigger(
     def trigger(self, status: RealtimeAcknowledgementStatus, response) -> None:
         self.received_resp = (status, response)
         if status == RealtimeAcknowledgementStatus.Ok:
+            self._cancel_timeout()
             for ok_callback in self.ok_callbacks:
                 ok_callback(response)
         elif status == RealtimeAcknowledgementStatus.Error:
+            self._cancel_timeout()
             for error_callback in self.error_callbacks:
                 error_callback(response)
         elif status == RealtimeAcknowledgementStatus.Timeout: