Improvements to ThenComposeAsyncTest for exception propagations

Author: vsilaev

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

@@ -287,10 +287,7 @@ public <U> Promise<U> thenComposeAsync(Function<? super T, ? extends CompletionS
                     moveToNextStage.accept(null, ex);  
                 }
             }), 
-            e -> { 
-                moveToNextStage.accept(null, e); 
-                return null; 
-            },
+            consumerAsFunction(e -> moveToNextStage.accept(null, e)),
             executor
         );
 

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

@@ -17,6 +17,9 @@
 
 import static org.junit.Assert.fail;
 
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import org.junit.After;
 import org.junit.Assert;
@@ -86,8 +89,11 @@ public void testThenComposeException() {
                     throw new IllegalStateException("oh no!");
                 });
         try {
-            p.get();
-        } catch (Exception ex) {
+            p.get(1L, TimeUnit.SECONDS);
+        } catch (TimeoutException ex) {
+            fail("thenCompose*  hanged");
+        } catch (InterruptedException | ExecutionException ex) {
+            // System.out.println(ex);
             // expected
             return;
         }