diff --git a/tests/test_resource_cache.py b/tests/test_resource_cache.py
index 74b00364..e7958b9c 100644
--- a/tests/test_resource_cache.py
+++ b/tests/test_resource_cache.py
@@ -173,7 +173,7 @@ async def maybe_open_stream(taskname: str):
 
         bstream = stream._broadcaster
         if (
-            not bstream.state.subs
+            not bstream._state.subs
             and
             not cache_hit
         ):