@NotThreadSafe public class ReadResponseMarshaller extends DataMessageMarshaller<ReadResponse>
ReadResponse
.Constructor and Description |
---|
ReadResponseMarshaller()
Creates a
ReadResponseMarshaller . |
Modifier and Type | Method and Description |
---|---|
ReadResponse |
combineData(DataMessage<ReadResponse,DataBuffer> message)
Combines the data buffer into the message.
|
protected ReadResponse |
deserialize(io.grpc.internal.ReadableBuffer buffer)
Deserialize data buffer to the message.
|
protected io.netty.buffer.ByteBuf[] |
serialize(ReadResponse message)
Serialize the message to buffers.
|
close, offerBuffer, parse, pollBuffer, stream
public ReadResponseMarshaller()
ReadResponseMarshaller
.protected io.netty.buffer.ByteBuf[] serialize(ReadResponse message) throws IOException
DataMessageMarshaller
serialize
in class DataMessageMarshaller<ReadResponse>
message
- the message to be serializedByteBuf
s containing the serialized messageIOException
- if the marshaller fails to serialize the messageprotected ReadResponse deserialize(io.grpc.internal.ReadableBuffer buffer) throws IOException
DataMessageMarshaller
deserialize
in class DataMessageMarshaller<ReadResponse>
buffer
- the buffer that contains the message dataIOException
- if the marshaller fails to deserialize the datapublic ReadResponse combineData(DataMessage<ReadResponse,DataBuffer> message)
DataMessageMarshaller
combineData
in class DataMessageMarshaller<ReadResponse>
message
- the message to be combinedCopyright © 2023. All Rights Reserved.