public interface Deframer
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this deframer and frees any resources.
|
void |
closeWhenComplete()
Close when any messages currently queued have been requested and delivered.
|
void |
deframe(ReadableBuffer data)
Adds the given data to this deframer and attempts delivery to the listener.
|
void |
request(int numMessages)
Requests up to the given number of messages from the call.
|
void |
setDecompressor(Decompressor decompressor)
Sets the decompressor available to use.
|
void |
setFullStreamDecompressor(io.grpc.internal.GzipInflatingBuffer fullStreamDecompressor)
Sets the decompressor used for full-stream decompression.
|
void |
setMaxInboundMessageSize(int messageSize) |
void setMaxInboundMessageSize(int messageSize)
void setDecompressor(Decompressor decompressor)
decompressor
- the decompressing wrapper.void setFullStreamDecompressor(io.grpc.internal.GzipInflatingBuffer fullStreamDecompressor)
setDecompressor(io.grpc.Decompressor)
.fullStreamDecompressor
- the decompressing wrappervoid request(int numMessages)
If close()
has been called, this method will have no effect.
numMessages
- the requested number of messages to be delivered to the listener.void deframe(ReadableBuffer data)
data
- the raw data read from the remote endpoint. Must be non-null.void closeWhenComplete()
void close()
Copyright © 2019. All rights reserved.