improving SlowConsumerTest

real-logic · Sep 5, 2024 · 157fdd2 · 157fdd2
1 parent 80200ca
commit 157fdd2
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java
@@ -263,15 +263,14 @@ private ConnectedSessionInfo sessionBecomesSlow(final MessageTimingCaptor messag
  assertNotSlow();
 
  // Get into a slow state
- while (sessionInfo.bytesInBuffer() == 0 || !handler.isSlow(session))
+ while (!handler.isSlow(session))
  {
  for (int i = 0; i < 10; i++)
  {
  sendMessageWithRetry();
  }
-
- testSystem.poll();
  }
+ testSystem.poll();
 
  assertIsSlow();
  return sessionInfo;