Package io.grpc.internal
Interface Framer
-
- All Known Implementing Classes:
AbstractClientStream.GetFramer,MessageFramer
public interface FramerInterface for framing gRPC messages.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidclose()Closes, with flush.voiddispose()Closes, without flush.voidflush()Flush the buffered payload.booleanisClosed()Returns whether the framer is closed.FramersetCompressor(Compressor compressor)Set the compressor used for compression.voidsetMaxOutboundMessageSize(int maxSize)Set a size limit for each outbound message.FramersetMessageCompression(boolean enable)Enable or disable compression.voidwritePayload(java.io.InputStream message)Writes out a payload message.
-
-
-
Method Detail
-
writePayload
void writePayload(java.io.InputStream message)
Writes out a payload message.- Parameters:
message- contains the message to be written out. It will be completely consumed.
-
flush
void flush()
Flush the buffered payload.
-
isClosed
boolean isClosed()
Returns whether the framer is closed.
-
close
void close()
Closes, with flush.
-
dispose
void dispose()
Closes, without flush.
-
setMessageCompression
Framer setMessageCompression(boolean enable)
Enable or disable compression.
-
setCompressor
Framer setCompressor(Compressor compressor)
Set the compressor used for compression.
-
setMaxOutboundMessageSize
void setMaxOutboundMessageSize(int maxSize)
Set a size limit for each outbound message.
-
-