This message was deleted.

For example in this case below, if createAsync() throws an exception directly, the

future

will never get completed. This kind of problem is very hard to troubleshooting cause it could haven’t any log.

CompletableFuture<xxx> future = new CompletableFuture<>();
xxx.whenComplete((v, ex) -> {
    xxx.createAsync().whenComplete((v, ex) -> {
        if (ex != null) {
            future.completeExceptionally(ex);
        } else {
            future.complete(v);
        }
    });
})

@Tom (Xiatech)

Yes, it should return a failed future here

Ok, I’ll open a PR later.

Ressurecting this old thread - as i am still encountering silently failing sinks and sources - it looks like your PR has been given change request