Rename Completion::wrap to toRun

Author: fluentfuture

mug/src/main/java/com/google/mu/util/concurrent/Completion.java

@@ -21,10 +21,10 @@ final class Completion implements AutoCloseable {
   private final Phaser phaser = new Phaser(1);
 
   void run(Runnable task) {
-    wrap(task).run();
+    toRun(task).run();
   }
 
-  Runnable wrap(Runnable task) {
+  Runnable toRun(Runnable task) {
     phaser.register();
     return () -> {
       try {

mug/src/main/java/com/google/mu/util/concurrent/Fanout.java

@@ -481,17 +481,17 @@ Scope add(Runnable... tasks) {
     }
 
     void run() throws StructuredConcurrencyInterruptedException {
-      try (Completion completion = new Completion()){
-        withUnlimitedConcurrency().parallelize(runnables.stream().map(completion::wrap));
+      try (Completion completion = new Completion()) {
+        withUnlimitedConcurrency().parallelize(runnables.stream().map(completion::toRun));
       } catch (InterruptedException e) {
         throw new StructuredConcurrencyInterruptedException(e);
       }
     }
 
     @Deprecated
     void runUninterruptibly() {
-      try (Completion completion = new Completion()){
-        withUnlimitedConcurrency().parallelizeUninterruptibly(runnables.stream().map(completion::wrap));
+      try (Completion completion = new Completion()) {
+        withUnlimitedConcurrency().parallelizeUninterruptibly(runnables.stream().map(completion::toRun));
       }
     }
   }

mug/src/test/java/com/google/mu/util/concurrent/CompletionTest.java

@@ -36,7 +36,7 @@ public class CompletionTest {
     AtomicBoolean done = new AtomicBoolean();
     try (Completion completion = new Completion()) {
       completion.run(() -> {});
-      new Thread(completion.wrap(() -> {
+      new Thread(completion.toRun(() -> {
         done.set(true);
       })).start();
     }
@@ -46,7 +46,7 @@ public class CompletionTest {
   @Test public void twoTasks_failed() throws Exception {
     AtomicBoolean done = new AtomicBoolean();
     try (Completion completion = new Completion()) {
-      new Thread(completion.wrap(() -> {
+      new Thread(completion.toRun(() -> {
         done.set(true);
       })).start();
       completion.run(() -> {