[KAFKA-6900] Add thenCompose to KafkaFuture

• Type: Improvement
• Status: Patch Available
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Component/s: clients
• Assignee: Unassigned
• Reporter: Richard Tjerngren
• Created: 14/May/18 15:11
• Updated: 03/Jun/18 20:59

Description

KafkaFuture supports Future chaining via the thenApply method just like CompletableFuture, however, thenApply is not intended to be used for lambdas that in turn return a future:

 

KafkaFutureImpl<String> future = new KafkaFutureImpl<>();
KafkaFuture<KafkaFuture<String>> nestedFuture = future.thenApply(result -> methodThatReturnsFuture(result));

Completable future has a method called thenCompose javadoc

The would be:

public KafkaFuture<R> thenCompose(Function<T, KafkaFuture<T> func);

So the above example would look like this:

KafkaFutureImpl<String> future = new KafkaFutureImpl<>();
KafkaFuture<String> nestedFuture = future.thenCompose(result -> methodThatReturnsFuture(result));

This would enable developers to chain asynchronous calls in a more natural way and it also makes KafkaFuture behave more similar to Javas CompletableFuture and Javascripts Promise

 

Issue Links

• links to: GitHub Pull Request #5080