diff --git a/google/cloud/firestore_v1/watch.py b/google/cloud/firestore_v1/watch.py index 63bb522b9..62b53ef4a 100644 --- 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.")