[Java] await recently added subscription in StreamStatTest (#1733)

aeron-io · Jan 28, 2025 · 7cbef12 · 7cbef12
1 parent e390850
commit 7cbef12
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aeron-samples/src/test/java/io/aeron/samples/StreamStatTest.java b/aeron-samples/src/test/java/io/aeron/samples/StreamStatTest.java
@@ -151,7 +151,7 @@ void shouldCollectStreamStats()
 
         final Subscription sub5 = aeron.addSubscription(pub4.channel(), pub4.streamId());
         assertNotSame(sub4, sub5);
-        Tests.awaitConnected(sub4);
+        Tests.awaitConnected(sub5);
         final CountingFragmentHandler sub1Handler = new CountingFragmentHandler(sub1);
         final CountingFragmentHandler sub2Handler = new CountingFragmentHandler(sub2);
         final CountingFragmentHandler sub4Handler = new CountingFragmentHandler(sub4);