Future.reduce considers executor (#2430)

vavr-io · Jul 22, 2019 · 65e42e3 · 65e42e3
1 parent 54a3d31
commit 65e42e3
Showing 1 changed file with 1 addition and 1 deletion.
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));
         }
     }