diff --git a/test/system/broadcasts_test.rb b/test/system/broadcasts_test.rb
index 6a2ca3e2..a4b5d763 100644
--- a/test/system/broadcasts_test.rb
+++ b/test/system/broadcasts_test.rb
@@ -43,7 +43,7 @@ def subscribe_to_broadcasts
 
     assert_no_button "Start listening for broadcasts"
 
-    Timeout.timeout(Capybara.default_max_wait_time) { wait_for_subscriber }
+    assert_selector :element, "turbo-cable-stream-source", visible: false
   end
 
   def assert_broadcasts_text(text, to:, &block)
@@ -53,18 +53,4 @@ def assert_broadcasts_text(text, to:, &block)
 
     within(:element, id: to) { assert_text text }
   end
-
-  def wait_for_subscriber
-    loop do
-      subscriber_map = ActionCable.server.pubsub.instance_variable_get(:@subscriber_map)
-      if subscriber_map.is_a?(ActionCable::SubscriptionAdapter::SubscriberMap)
-        subscribers = subscriber_map.instance_variable_get(:@subscribers)
-        sync = subscriber_map.instance_variable_get(:@sync)
-        sync.synchronize do
-          return unless subscribers.empty?
-        end
-      end
-      sleep 0.1
-    end
-  end
 end