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	setInternalCallback(PubSubProducerCallback callback)	Add internal callback into the current 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()

setInternalCallback

public void setInternalCallback(PubSubProducerCallback callback)

Description copied from interface: PubSubProducerCallback

Add internal callback into the current callback. Default behavior is doing nothing.

Specified by:

setInternalCallback in interface PubSubProducerCallback

getCompletableFuture

public CompletableFuture<Void> getCompletableFuture()

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable