fix: clean up resources on Watch close (#1004)

googleapis · Jan 10, 2025 · 6d68dcd · 6d68dcd
1 parent 583dc58
commit 6d68dcd
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/google/cloud/firestore_v1/watch.py b/google/cloud/firestore_v1/watch.py
@@ -333,9 +333,13 @@ def close(self, reason=None):
             if self.is_active:
                 _LOGGER.debug("Stopping consumer.")
                 self._consumer.stop()
+            self._consumer._on_response = None
             self._consumer = None
 
+            self._snapshot_callback = None
             self._rpc.close()
+            self._rpc._initial_request = None
+            self._rpc._callbacks = []
             self._rpc = None
             self._closed = True
             _LOGGER.debug("Finished stopping manager.")