Future.reduce considers executor (#2430)

danieldietrich · danieldietrich · commit 65e42e3d6ac7 · 2019-07-23T01:38:28.000+02:00
diff --git a/vavr/src/main/java/io/vavr/concurrent/Future.java b/vavr/src/main/java/io/vavr/concurrent/Future.java
@@ -610,7 +610,7 @@ static <T> Future<T> reduce(Executor executor, Iterable<? extends Future<? exten
         if (!futures.iterator().hasNext()) {
             throw new NoSuchElementException("Future.reduce on empty futures");
         } else {
-            return Future.<T> sequence(futures).map(seq -> seq.reduceLeft(f));
+            return Future.sequence(executor, futures).map(seq -> seq.reduceLeft(f));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -610,7 +610,7 @@ static <T> Future<T> reduce(Executor executor, Iterable<? extends Future<? exten`
`610`	`610`	`if (!futures.iterator().hasNext()) {`
`611`	`611`	`throw new NoSuchElementException("Future.reduce on empty futures");`
`612`	`612`	`} else {`
`613`		`- return Future.<T> sequence(futures).map(seq -> seq.reduceLeft(f));`
	`613`	`+ return Future.sequence(executor, futures).map(seq -> seq.reduceLeft(f));`
`614`	`614`	`}`
`615`	`615`	`}`
`616`	`616`