Class AbstractClientStream.GetFramer

java.lang.Object
io.grpc.internal.AbstractClientStream.GetFramer
All Implemented Interfaces:
Framer
Enclosing class:
AbstractClientStream

private class AbstractClientStream.GetFramer extends Object implements Framer
  • Field Details

    • headers

      private Metadata headers
    • closed

      private boolean closed
    • statsTraceCtx

      private final StatsTraceContext statsTraceCtx
    • payload

      private byte[] payload
  • Constructor Details

  • Method Details

    • writePayload

      public void writePayload(InputStream message)
      Description copied from interface: Framer
      Writes out a payload message.
      Specified by:
      writePayload in interface Framer
      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.
      Specified by:
      flush in interface Framer
    • isClosed

      public boolean isClosed()
      Description copied from interface: Framer
      Returns whether the framer is closed.
      Specified by:
      isClosed in interface Framer
    • close

      public void close()
      Closes, with flush.
      Specified by:
      close in interface Framer
    • dispose

      public void dispose()
      Closes, without flush.
      Specified by:
      dispose in interface Framer
    • setMessageCompression

      public Framer setMessageCompression(boolean enable)
      Description copied from interface: Framer
      Enable or disable compression.
      Specified by:
      setMessageCompression in interface Framer
    • setCompressor

      public Framer setCompressor(Compressor compressor)
      Description copied from interface: Framer
      Set the compressor used for compression.
      Specified by:
      setCompressor in interface Framer
    • setMaxOutboundMessageSize

      public void setMaxOutboundMessageSize(int maxSize)
      Description copied from interface: Framer
      Set a size limit for each outbound message.
      Specified by:
      setMaxOutboundMessageSize in interface Framer