Interface TransportClientStreamingCallback
-
- All Known Subinterfaces:
RecordStreamDecoder
- All Known Implementing Classes:
AbstractRecordStreamDecoder
,ClientComputeRecordStreamDecoder
,ComputeRecordStreamDecoder
,MultiGetRecordStreamDecoder
public interface TransportClientStreamingCallback
Callback to support streaming inTransportClient
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onCompletion(java.util.Optional<VeniceClientException> exception)
This will be invoked when the response is fully completed.void
onDataReceived(java.nio.ByteBuffer chunk)
This will be invoked when a new data chunk is available.void
onHeaderReceived(java.util.Map<java.lang.String,java.lang.String> headers)
This will be invoked when headers are available.
-
-
-
Method Detail
-
onHeaderReceived
void onHeaderReceived(java.util.Map<java.lang.String,java.lang.String> headers)
This will be invoked when headers are available.- Parameters:
headers
-
-
onDataReceived
void onDataReceived(java.nio.ByteBuffer chunk)
This will be invoked when a new data chunk is available.- Parameters:
chunk
-
-
onCompletion
void onCompletion(java.util.Optional<VeniceClientException> exception)
This will be invoked when the response is fully completed. When any error happens, {@param exception} will contain the underlying exception.- Parameters:
exception
-
-
-