timeout

ExceptionallyAndTimeoutExample.java

        CompletableFuture<String> subTask = new CompletableFuture<>();

        CompletableFuture<Result> chain = CompletableFuture.runAsync(() -> System.out.println("Start"))
                .thenCombine(subTask, (nil, text) -> {
                    if (text == null || text.isEmpty())
                        throw new IllegalArgumentException("Text cannot be null or empty!");
                    return Result.COMPLETED;
                })
                .completeOnTimeout(Result.TIMEOUT, 500, TimeUnit.MILLISECONDS)
                .exceptionally(exception -> Result.FAILED);

        final Result result = chain.get();
        System.out.println("Result is : " + result);