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