formatting fixes.

Author: cconstable

temporal-sdk/src/main/java/io/temporal/internal/concurrent/structured/AsyncTask.java

@@ -7,8 +7,8 @@
 import java.util.function.Function;
 
 /**
- * Internal task handle over a {@link CompletableFuture} that manages cancellation
- * and tracks derived tasks.
+ * Internal task handle over a {@link CompletableFuture} that manages cancellation and tracks
+ * derived tasks.
  *
  * <p><strong>Continuation style.</strong> {@link #map}, {@link #recover}, and {@link #whenSettled}
  * chain follow-on work, mirroring {@code thenApply}/{@code exceptionally}/{@code whenComplete}.

temporal-sdk/src/main/java/io/temporal/internal/concurrent/structured/CancelSource.java

@@ -5,8 +5,8 @@
 import java.util.List;
 
 /**
- * The <em>write</em> side of cancellation. Whoever holds the {@code CancelSource} can
- * request cancellation while everyone else observes using {@link #token()}.
+ * The <em>write</em> side of cancellation. Whoever holds the {@code CancelSource} can request
+ * cancellation while everyone else observes using {@link #token()}.
  */
 public final class CancelSource {
 

temporal-sdk/src/main/java/io/temporal/internal/concurrent/structured/DefaultAsyncTask.java

@@ -11,9 +11,7 @@
 import java.util.function.Consumer;
 import java.util.function.Function;
 
-/**
- * Reference implementation of {@link AsyncTask}.
- */
+/** Reference implementation of {@link AsyncTask}. */
 final class DefaultAsyncTask<T> implements AsyncTask<T> {
 
   final CompletableFuture<T> cf;

temporal-sdk/src/main/java/io/temporal/internal/concurrent/structured/DefaultTaskScope.java

@@ -190,8 +190,8 @@ public void close() {
 
   /**
    * Non-blocking completion for {@link TaskScope#withScope}: when {@code body} settles, cancels the
-   * group on failure, waits for every task to settle, then delivers the outcome. The returned future
-   * does not settle until all tasks have, so no task outlives the scope.
+   * group on failure, waits for every task to settle, then delivers the outcome. The returned
+   * future does not settle until all tasks have, so no task outlives the scope.
    */
   <R> CompletableFuture<R> closeWhenDone(CompletableFuture<R> body) {
     CompletableFuture<R> delivered = new CompletableFuture<>();
@@ -219,7 +219,9 @@ private CompletableFuture<Void> allTerminated() {
     return awaitTermination(0, null);
   }
 
-  /** Runs {@code body} against {@code scope} and ties the scope's lifetime to the returned future. */
+  /**
+   * Runs {@code body} against {@code scope} and ties the scope's lifetime to the returned future.
+   */
   static <T, R> CompletableFuture<R> run(
       DefaultTaskScope<T> scope, Function<TaskScope<T>, CompletableFuture<R>> body) {
     CompletableFuture<R> future;

temporal-sdk/src/main/java/io/temporal/internal/concurrent/structured/TaskChain.java

@@ -10,8 +10,8 @@ public interface TaskChain<T> {
   <R> TaskChain<R> map(Function<? super T, ? extends R> fn);
 
   /**
-   * Supplies a fallback value if this chain fails. Unlike {@code CompletableFuture.exceptionally}, a
-   * cancelled chain is not recovered (cancellation propagates) and the fallback receives the
+   * Supplies a fallback value if this chain fails. Unlike {@code CompletableFuture.exceptionally},
+   * a cancelled chain is not recovered (cancellation propagates) and the fallback receives the
    * unwrapped cause.
    */
   TaskChain<T> recover(Function<? super Throwable, ? extends T> fn);

temporal-sdk/src/main/java/io/temporal/internal/concurrent/structured/TaskScope.java

@@ -59,9 +59,9 @@ default CompletableFuture<List<T>> awaitAll() {
   /**
    * Non-blocking fail-fast wait that collects all task results and passes them to a transformer.
    *
-   * <p>The returned future completes after all collected tasks complete successfully. Attached tasks
-   * are collected by default; when a collected task is transformed, the transformed child replaces
-   * its parent in the collected result list. On first failure or cancellation it completes
+   * <p>The returned future completes after all collected tasks complete successfully. Attached
+   * tasks are collected by default; when a collected task is transformed, the transformed child
+   * replaces its parent in the collected result list. On first failure or cancellation it completes
    * exceptionally and cancels unfinished tasks.
    *
    * <p>This method does not close the scope. Scope lifetime remains caller-owned.

temporal-sdk/src/test/java/io/temporal/internal/common/ListUtilsTest.java

@@ -16,7 +16,8 @@ public class ListUtilsTest {
   @Test
   public void flattensNestedCollectionsInOrder() {
     List<Integer> flat =
-        ListUtils.flatten(Arrays.asList(Arrays.asList(1, 2), Arrays.asList(3), Arrays.asList(4, 5)));
+        ListUtils.flatten(
+            Arrays.asList(Arrays.asList(1, 2), Arrays.asList(3), Arrays.asList(4, 5)));
 
     assertEquals(Arrays.asList(1, 2, 3, 4, 5), flat);
   }