Bump POM version for next iteration; simplify ExecutorBoundCompletionStage logic

Author: vsilaev

pom.xml

@@ -4,7 +4,7 @@
 
 	<groupId>net.tascalate.concurrent</groupId>
 	<artifactId>net.tascalate.concurrent.lib</artifactId>
-	<version>0.6.3</version>
+	<version>0.6.4-SNAPSHOT</version>
 	<packaging>jar</packaging>  
 
 	<name>Tascalate Concurrenct</name>

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

@@ -41,7 +41,7 @@ public <U> CompletionStage<U> thenApply(Function<? super T, ? extends U> fn) {
     }
 
     public <U> CompletionStage<U> thenApplyAsync(Function<? super T, ? extends U> fn) {
-        return wrap(delegate.thenApplyAsync(fn, defaultExecutor));
+        return thenApplyAsync(fn, defaultExecutor);
     }
 
     public <U> CompletionStage<U> thenApplyAsync(Function<? super T, ? extends U> fn, Executor executor) {
@@ -53,7 +53,7 @@ public CompletionStage<Void> thenAccept(Consumer<? super T> action) {
     }
 
     public CompletionStage<Void> thenAcceptAsync(Consumer<? super T> action) {
-        return wrap(delegate.thenAcceptAsync(action, defaultExecutor));
+        return thenAcceptAsync(action, defaultExecutor);
     }
 
     public CompletionStage<Void> thenAcceptAsync(Consumer<? super T> action, Executor executor) {
@@ -65,7 +65,7 @@ public CompletionStage<Void> thenRun(Runnable action) {
     }
 
     public CompletionStage<Void> thenRunAsync(Runnable action) {
-        return wrap(delegate.thenRunAsync(action, defaultExecutor));
+        return thenRunAsync(action, defaultExecutor);
     }
 
     public CompletionStage<Void> thenRunAsync(Runnable action, Executor executor) {
@@ -77,7 +77,7 @@ public <U, V> CompletionStage<V> thenCombine(CompletionStage<? extends U> other,
     }
 
     public <U, V> CompletionStage<V> thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn) {
-        return wrap(delegate.thenCombineAsync(other, fn, defaultExecutor));
+        return thenCombineAsync(other, fn, defaultExecutor);
     }
 
     public <U, V> CompletionStage<V> thenCombineAsync(CompletionStage<? extends U> other,
@@ -92,7 +92,7 @@ public <U> CompletionStage<Void> thenAcceptBoth(CompletionStage<? extends U> oth
     }
 
     public <U> CompletionStage<Void> thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action) {
-        return wrap(delegate.thenAcceptBothAsync(other, action, defaultExecutor));
+        return thenAcceptBothAsync(other, action, defaultExecutor);
     }
 
     public <U> CompletionStage<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
@@ -107,7 +107,7 @@ public CompletionStage<Void> runAfterBoth(CompletionStage<?> other, Runnable act
     }
 
     public CompletionStage<Void> runAfterBothAsync(CompletionStage<?> other, Runnable action) {
-        return wrap(delegate.runAfterBothAsync(other, action, defaultExecutor));
+        return runAfterBothAsync(other, action, defaultExecutor);
     }
 
     public CompletionStage<Void> runAfterBothAsync(CompletionStage<?> other, 
@@ -121,7 +121,7 @@ public <U> CompletionStage<U> applyToEither(CompletionStage<? extends T> other,
     }
 
     public <U> CompletionStage<U> applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T, U> fn) {
-        return wrap(delegate.applyToEitherAsync(other, fn, defaultExecutor));
+        return applyToEitherAsync(other, fn, defaultExecutor);
     }
 
     public <U> CompletionStage<U> applyToEitherAsync(CompletionStage<? extends T> other, 
@@ -136,7 +136,7 @@ public CompletionStage<Void> acceptEither(CompletionStage<? extends T> other, Co
     }
 
     public CompletionStage<Void> acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action) {
-        return wrap(delegate.acceptEitherAsync(other, action, defaultExecutor));
+        return acceptEitherAsync(other, action, defaultExecutor);
     }
 
     public CompletionStage<Void> acceptEitherAsync(CompletionStage<? extends T> other, 
@@ -151,7 +151,7 @@ public CompletionStage<Void> runAfterEither(CompletionStage<?> other, Runnable a
     }
 
     public CompletionStage<Void> runAfterEitherAsync(CompletionStage<?> other, Runnable action) {
-        return wrap(delegate.runAfterEitherAsync(other, action, defaultExecutor));
+        return runAfterEitherAsync(other, action, defaultExecutor);
     }
 
     public CompletionStage<Void> runAfterEitherAsync(CompletionStage<?> other, 
@@ -165,7 +165,7 @@ public <U> CompletionStage<U> thenCompose(Function<? super T, ? extends Completi
     }
 
     public <U> CompletionStage<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn) {
-        return wrap(delegate.thenComposeAsync(fn, defaultExecutor));
+        return thenComposeAsync(fn, defaultExecutor);
     }
 
     public <U> CompletionStage<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor) {
@@ -181,7 +181,7 @@ public CompletionStage<T> whenComplete(BiConsumer<? super T, ? super Throwable>
     }
 
     public CompletionStage<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action) {
-        return wrap(delegate.whenCompleteAsync(action, defaultExecutor));
+        return whenCompleteAsync(action, defaultExecutor);
     }
 
     public CompletionStage<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor) {
@@ -193,7 +193,7 @@ public <U> CompletionStage<U> handle(BiFunction<? super T, Throwable, ? extends
     }
 
     public <U> CompletionStage<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn) {
-        return wrap(delegate.handleAsync(fn, defaultExecutor));
+        return handleAsync(fn, defaultExecutor);
     }
 
     public <U> CompletionStage<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) {