Refactoring Greek

Author: vsilaev

src/main/java/net/tascalate/concurrent/CompletableFutureWrapper.java

@@ -62,7 +62,7 @@ public CompletableFuture<T> toCompletableFuture() {
 
     // Report self-origin
     @Override
-    public CompletionStage<T> τ() {
+    public CompletionStage<T> α() {
         return this;
     }
 

src/main/java/net/tascalate/concurrent/CompletablePromise.java

@@ -120,7 +120,7 @@ public CompletableFuture<T> toCompletableFuture() {
     }
 
     @Override
-    public CompletionStage<T> τ() {
+    public CompletionStage<T> α() {
         return delegate;
     }
 

src/main/java/net/tascalate/concurrent/ConfigurableDependentPromise.java

@@ -834,8 +834,8 @@ public CompletableFuture<T> toCompletableFuture() {
 
     @Override
     public CompletableFuture<T> toCompletableFuture(boolean enlistOrigin) {
-        CompletionStage<T> tau = tauOf(delegate);
-        CompletableFuture<T> rootDelegate = tau instanceof CompletableFuture ? (CompletableFuture<T>)tau : null; 
+        CompletionStage<T> alpha = alphaOf(delegate);
+        CompletableFuture<T> rootDelegate = alpha instanceof CompletableFuture ? (CompletableFuture<T>)alpha : null; 
         CompletableFuture<T> result;
         if (enlistOrigin) {
             if (rootDelegate != null) {
@@ -866,8 +866,8 @@ public boolean cancel(boolean mayInterruptIfRunning) {
     }
 
     @Override
-    public CompletionStage<T> τ() {
-        return tauOf(delegate);
+    public CompletionStage<T> α() {
+        return alphaOf(delegate);
     }
 
     @Override
@@ -879,11 +879,11 @@ public String toString() {
         );
     }
 
-    private static <T> CompletionStage<T> tauOf(Promise<T> promise) {
+    private static <T> CompletionStage<T> alphaOf(Promise<T> promise) {
         if (promise instanceof Delegator) {
             @SuppressWarnings("unchecked")
             Delegator<T> delegator = (Delegator<T>)promise;
-            return delegator.τ();
+            return delegator.α();
         } else {
             return promise;
         }

src/main/java/net/tascalate/concurrent/DependentPromise.java

@@ -70,10 +70,10 @@ public interface DependentPromise<T> extends Promise<T> {
 
     @Override
     default <D> D as(Function<? super Promise<T>, D> decoratorFactory) {
-        return as_(decoratorFactory);
+        return asʹ(decoratorFactory);
     }
 
-    default <D> D as_(Function<? super DependentPromise<T>, D> decoratorFactory) {
+    default <D> D asʹ(Function<? super DependentPromise<T>, D> decoratorFactory) {
         return decoratorFactory.apply(this);
     }
 

src/main/java/net/tascalate/concurrent/core/Delegator.java

@@ -18,5 +18,5 @@
 import java.util.concurrent.CompletionStage;
 
 public interface Delegator<T> {
-    CompletionStage<T> τ();
+    CompletionStage<T> α();
 }

src/main/java/net/tascalate/concurrent/decorators/AbstractPromiseLikeDecorator.java

@@ -272,11 +272,12 @@ public <U> Promise<U> handleAsync(BiFunction<? super T, Throwable, ? extends U>
         return cast(super.handleAsync(fn, executor));
     }
 
-    // Tau-operator -- the origin of origins
-    public CompletionStage<T> τ() {
+    // Alpha-operator -- the origin of origins
+    @Override
+    public CompletionStage<T> α() {
         CompletionStage<T> p = delegate;
         if (p instanceof Delegator) {
-            return delegator(p).τ();
+            return delegator(p).α();
         } else {
             // Default path -- unroll
             while (p instanceof AbstractCompletionStageDecorator) {
@@ -285,7 +286,7 @@ public <U> Promise<U> handleAsync(BiFunction<? super T, Throwable, ? extends U>
                     (AbstractCompletionStageDecorator<T, ? extends CompletionStage<T>>)p;
                 p = ap.delegate;
                 if (p instanceof Delegator) {
-                    return delegator(p).τ();
+                    return delegator(p).α();
                 }
             }
             return p;

src/test/java/net/tascalate/concurrent/J8Examples.java

@@ -107,17 +107,17 @@ public static void main(final String[] argv) throws InterruptedException, Execut
 
         final TaskExecutorService executorService = TaskExecutors.newFixedThreadPool(6, tf);
 
-        System.out.println(new CustomizablePromiseDecorator<>(CompletableTask.completed("", executorService).defaultAsyncOn(executorService), null).τ());
-        System.out.println(new CustomizablePromiseDecorator<>(Promises.success(11).defaultAsyncOn(executorService), null).τ());
-        System.out.println(new CustomizablePromiseDecorator<>(new CompletablePromise<Long>().defaultAsyncOn(executorService), null).τ());
+        System.out.println(new CustomizablePromiseDecorator<>(CompletableTask.completed("", executorService).defaultAsyncOn(executorService), null).α());
+        System.out.println(new CustomizablePromiseDecorator<>(Promises.success(11).defaultAsyncOn(executorService), null).α());
+        System.out.println(new CustomizablePromiseDecorator<>(new CompletablePromise<Long>().defaultAsyncOn(executorService), null).α());
 
         Promise<?> t = 
         Promises.success("11")
         //CompletableTask
           //  .supplyAsync(() -> "11", executorService)
             .dependent()
-            .as_(peek(p -> p.thenApply(Integer::parseInt)))
-            .as_(peek(System.out::println))
+            .asʹ(peek(p -> p.thenApply(Integer::parseInt)))
+            .asʹ(peek(System.out::println))
             .thenComposeAsync(v -> {
                 System.out.println("In compose " + v);
                 try {
@@ -140,11 +140,10 @@ public static void main(final String[] argv) throws InterruptedException, Execut
                     throw new CompletionException(ex);
                 }
             }, executorService, true); 
-        
         Thread.sleep(500);
         t.cancel(true);
         System.out.println("Is cancelled ? " + t.isCancelled());
-        
+       
         AsyncSemaphoreLock lock = AsyncSemaphoreLock.create(7, true);
         for (int i = 0; i < 10; i++) {
             int idx  = i;