Fix formatting #3233

Author: sanurah

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

@@ -8,17 +8,16 @@
  * producer to slow down or stop sending data when it's overwhelmed.
  * <li>Prevents memory overflow, CPU thrashing, and resource exhaustion.
  * <li>Ensures fair usage of resources in distributed systems.
- * <li>Avoids buffer bloat and latency spikes.
- * Key concepts of this design paradigm involves
+ * <li>Avoids buffer bloat and latency spikes. Key concepts of this design paradigm involves
  * <li>Publisher/Producer: Generates data.
  * <li>Subscriber/Consumer: Receives and processes data.
  *
- * <p>In this example we will create a {@link Publisher} and a {@link Subscriber}. Publisher will
- * emit a stream of integer values with a predefined delay. Subscriber takes 500 ms to process one
- * integer. Since the subscriber can't process the items fast enough we apply backpressure to the
- * publisher so that it will request 10 items first, process 5 items and request for the next 5
- * again. After processing 5 items subscriber will keep requesting for another 5 until the stream
- * ends.
+ *     <p>In this example we will create a {@link Publisher} and a {@link Subscriber}. Publisher
+ *     will emit a stream of integer values with a predefined delay. Subscriber takes 500 ms to
+ *     process one integer. Since the subscriber can't process the items fast enough we apply
+ *     backpressure to the publisher so that it will request 10 items first, process 5 items and
+ *     request for the next 5 again. After processing 5 items subscriber will keep requesting for
+ *     another 5 until the stream ends.
  */
 @Slf4j
 public class App {
@@ -52,4 +51,4 @@ public static void main(String[] args) throws InterruptedException {
     latch = new CountDownLatch(1);
     latch.await();
   }
-}
+}

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

@@ -3,9 +3,7 @@
 import java.time.Duration;
 import reactor.core.publisher.Flux;
 
-/**
- * This class is the publisher that generates the data stream.
- */
+/** This class is the publisher that generates the data stream. */
 public class Publisher {
 
   /**

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

@@ -7,17 +7,15 @@
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.BaseSubscriber;
 
-/**
- * This class is the custom subscriber that subscribes to the data stream.
- */
+/** This class is the custom subscriber that subscribes to the data stream. */
 @Slf4j
 public class Subscriber extends BaseSubscriber<Integer> {
 
   private static final Logger logger = LoggerFactory.getLogger(Subscriber.class);
 
   @Override
   protected void hookOnSubscribe(@NonNull Subscription subscription) {
-    request(10); //request 10 items initially
+    request(10); // request 10 items initially
   }
 
   @Override

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

@@ -12,7 +12,7 @@ public class PublisherTest {
   @Test
   public void testPublish() {
 
-    Flux<Integer>  flux = publish(1, 3, 200);
+    Flux<Integer> flux = publish(1, 3, 200);
 
     StepVerifier.withVirtualTime(() -> flux)
         .expectSubscription()

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

@@ -8,8 +8,7 @@
 
 public class SubscriberTest {
 
-  @RegisterExtension
-  public LoggerExtension loggerExtension = new LoggerExtension();
+  @RegisterExtension public LoggerExtension loggerExtension = new LoggerExtension();
 
   @Test
   public void testSubscribe() throws InterruptedException {
@@ -21,9 +20,11 @@ public void testSubscribe() throws InterruptedException {
     App.latch.await();
 
     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()"));
+    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()"));
   }
 }