We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c7feaa1 commit 809330fCopy full SHA for 809330f
tests/unit/v1/test_watch.py
@@ -400,6 +400,15 @@ def test_watch_on_snapshot_target_w_none():
400
assert inst._rpc is None
401
402
403
+def test_watch_on_snapshot_while_closing():
404
+ inst = _make_watch()
405
+ inst.close = mock.Mock()
406
+ with inst._closing:
407
+ inst.on_snapshot(mock.Mock())
408
+ # close should not be called again when already closing
409
+ inst.close.assert_not_called()
410
+
411
412
def test_watch_on_snapshot_target_no_change_no_target_ids_not_current():
413
inst = _make_watch()
414
proto = _make_listen_response()
0 commit comments