docs: @SuppressWarnings("unchecked")
    public static <T> CompletableFuture<Stream<T>> allOf(Stream<CompletableFuture<T>> futures) {
      CompletableFuture<T>[] futuresArray = futures.toArray(CompletableFuture[]::new);
      return AtomixFuture.wrap(CompletableFuture.allOf(futuresArray)
          .thenApply(v -> Stream.of(futuresArray).map(CompletableFuture::join)));
    }