Package com.linkedin.venice.client.store.transport

Interface TransportClientStreamingCallback

All Known Subinterfaces:

RecordStreamDecoder

All Known Implementing Classes:

AbstractRecordStreamDecoder, ClientComputeRecordStreamDecoder, ComputeRecordStreamDecoder, MultiGetRecordStreamDecoder

public interface TransportClientStreamingCallback

Callback to support streaming in TransportClient

Method Summary

Modifier and Type	Method	Description
void	onCompletion(Optional<VeniceClientException> exception)	This will be invoked when the response is fully completed.
void	onDataReceived(ByteBuffer chunk)	This will be invoked when a new data chunk is available.
void	onHeaderReceived(Map<String,String> headers)	This will be invoked when headers are available.

Method Details

onHeaderReceived

void onHeaderReceived(Map<String,String> headers)

This will be invoked when headers are available.

Parameters:

headers -

onDataReceived

void onDataReceived(ByteBuffer chunk)

This will be invoked when a new data chunk is available.

Parameters:

chunk -

onCompletion

void onCompletion(Optional<VeniceClientException> exception)

This will be invoked when the response is fully completed. When any error happens, will contain the underlying exception.

Parameters:

exception -