CompletableFuture#thenCompose isn't stack-safe, so c-switch zips for now

jnape · jnape · commit bc366576d65c · 2019-05-19T18:59:40.000-05:00
diff --git a/src/main/java/com/jnape/palatable/lambda/io/IO.java b/src/main/java/com/jnape/palatable/lambda/io/IO.java
@@ -312,10 +312,10 @@ public CompletableFuture<A> unsafePerformAsyncIO(Executor executor) {
             @SuppressWarnings("unchecked")
             CompletableFuture<A> future = (CompletableFuture<A>) deforest(new LinkedList<>())
                     .into((source, compositions) -> foldLeft(
-                            (io, composition) -> composition
+                            (ioFuture, composition) -> composition
                                     .match(zip -> zip.unsafePerformAsyncIO(executor)
-                                                   .thenCompose(f -> io.thenApply(f.toFunction())),
-                                           flatMap -> io.thenComposeAsync(obj -> flatMap.apply(obj)
+                                                   .thenComposeAsync(f -> ioFuture.thenApply(f.toFunction()), executor),
+                                           flatMap -> ioFuture.thenComposeAsync(obj -> flatMap.apply(obj)
                                                    .unsafePerformAsyncIO(executor), executor)),
                             source.unsafePerformAsyncIO(executor),
                             compositions));
