We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c0f2c9b commit ec8a056Copy full SHA for ec8a056
1 file changed
contrib/temporal-payload-storage-s3/src/main/java/io/temporal/payload/storage/s3/CompletableFutures.java
@@ -7,6 +7,16 @@
7
final class CompletableFutures {
8
private CompletableFutures() {}
9
10
+ /**
11
+ * Returns a future that completes when all of the given futures complete, yielding a list of
12
+ * their results. If any future completes exceptionally, the returned future also completes
13
+ * exceptionally with the same exception. If the input list is empty, the returned future completes
14
+ * immediately with an empty list.
15
+ *
16
+ * @param <T>
17
+ * @param futures
18
+ * @return
19
+ */
20
static <T> CompletableFuture<List<T>> allOf(List<CompletableFuture<T>> futures) {
21
return CompletableFuture.allOf(futures.toArray(new CompletableFuture<?>[0]))
22
.thenApply(
0 commit comments