Package com.linkedin.venice.writer

Class CompletableFutureCallback

java.lang.Object

com.linkedin.venice.writer.CompletableFutureCallback

All Implemented Interfaces:

Measurable, PubSubProducerCallback

public class CompletableFutureCallback
extends Object
implements PubSubProducerCallback, Measurable

Compose a CompletableFuture and Callback together to be a CompletableFutureCallback type. When the CompletableFutureCallback is called, the CompletableFuture internal state will be changed and the callback will be called. The caller can pass a CompletableFutureCallback to a function accepting a Callback parameter to get a CompletableFuture after the function returns.

Constructor Summary

Constructors

Constructor	Description
CompletableFutureCallback(CompletableFuture<Void> completableFuture)

Method Summary

Modifier and Type	Method	Description
PubSubProducerCallback	getCallback()
CompletableFuture<Void>	getCompletableFuture()
int	getHeapSize()
void	onCompletion(PubSubProduceResult produceResult, Exception e)	exception will be null if request was completed without an error.
void	setCallback(PubSubProducerCallback callback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CompletableFutureCallback

public CompletableFutureCallback(CompletableFuture<Void> completableFuture)

Method Details

onCompletion

public void onCompletion(PubSubProduceResult produceResult,
 Exception e)

Description copied from interface: PubSubProducerCallback

exception will be null if request was completed without an error.

Specified by:

onCompletion in interface PubSubProducerCallback

getCallback

public PubSubProducerCallback getCallback()

setCallback

public void setCallback(PubSubProducerCallback callback)

getCompletableFuture

public CompletableFuture<Void> getCompletableFuture()

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable