Fix test case #3233

Author: sanurah

backpressure/src/main/java/com/iluwatar/backpressure/Subscriber.java

@@ -17,7 +17,6 @@ public class Subscriber extends BaseSubscriber<Integer> {
 
   @Override
   protected void hookOnSubscribe(@NonNull Subscription subscription) {
-    logger.info("subscribe()");
     request(10); //request 10 items initially
   }
 

backpressure/src/test/java/com/iluwatar/backpressure/SubscriberTest.java

@@ -1,6 +1,6 @@
 package com.iluwatar.backpressure;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 import java.util.concurrent.CountDownLatch;
 import org.junit.jupiter.api.Test;
@@ -13,14 +13,17 @@ public class SubscriberTest {
 
   @Test
   public void testSubscribe() throws InterruptedException {
-    App.latch = new CountDownLatch(1);
+
     Subscriber sub = new Subscriber();
     Publisher.publish(1, 8, 100).subscribe(sub);
 
+    App.latch = new CountDownLatch(1);
     App.latch.await();
-    assertEquals(22, loggerExtension.getFormattedMessages().size());
-    assertEquals("subscribe()", loggerExtension.getFormattedMessages().get(2));
-    assertEquals("request(10)", loggerExtension.getFormattedMessages().get(3));
-    assertEquals("request(5)", loggerExtension.getFormattedMessages().get(14));
+
+    String result = String.join(",", loggerExtension.getFormattedMessages());
+    assertTrue(result.endsWith("onSubscribe(FluxConcatMapNoPrefetch." +
+        "FluxConcatMapNoPrefetchSubscriber),request(10),onNext(1),process(1),onNext(2)," +
+        "process(2),onNext(3),process(3),onNext(4),process(4),onNext(5),process(5),request(5)," +
+        "onNext(6),process(6),onNext(7),process(7),onNext(8),process(8),onComplete()"));
   }
 }