Package io.grpc.internal
Class AbstractClientStream.GetFramer
java.lang.Object
io.grpc.internal.AbstractClientStream.GetFramer
- All Implemented Interfaces:
Framer
- Enclosing class:
AbstractClientStream
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private Metadata
private byte[]
private final StatsTraceContext
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Closes, with flush.void
dispose()
Closes, without flush.void
flush()
Flush the buffered payload.boolean
isClosed()
Returns whether the framer is closed.setCompressor
(Compressor compressor) Set the compressor used for compression.void
setMaxOutboundMessageSize
(int maxSize) Set a size limit for each outbound message.setMessageCompression
(boolean enable) Enable or disable compression.void
writePayload
(InputStream message) Writes out a payload message.
-
Field Details
-
headers
-
closed
private boolean closed -
statsTraceCtx
-
payload
private byte[] payload
-
-
Constructor Details
-
GetFramer
-
-
Method Details
-
writePayload
Description copied from interface:Framer
Writes out a payload message.- Specified by:
writePayload
in interfaceFramer
- Parameters:
message
- contains the message to be written out. It will be completely consumed.
-
flush
public void flush()Description copied from interface:Framer
Flush the buffered payload. -
isClosed
public boolean isClosed()Description copied from interface:Framer
Returns whether the framer is closed. -
close
public void close()Closes, with flush. -
dispose
public void dispose()Closes, without flush. -
setMessageCompression
Description copied from interface:Framer
Enable or disable compression.- Specified by:
setMessageCompression
in interfaceFramer
-
setCompressor
Description copied from interface:Framer
Set the compressor used for compression.- Specified by:
setCompressor
in interfaceFramer
-
setMaxOutboundMessageSize
public void setMaxOutboundMessageSize(int maxSize) Description copied from interface:Framer
Set a size limit for each outbound message.- Specified by:
setMaxOutboundMessageSize
in interfaceFramer
-