public static <T> void complete(Iterator<CompletableFuture<T>> futures, T value) {
        while (futures.hasNext()) {
            CompletableFuture<T> future = futures.next();
            future.complete(value);
        }
    }
Catch exceptions as a last resort to avoid unresponsiveness.
s3stream/src/main/java/com/automq/stream/utils/FutureUtil.java