Class AbstractClientStream.GetFramer

  • All Implemented Interfaces:
    Framer
    Enclosing class:
    AbstractClientStream

    private class AbstractClientStream.GetFramer
    extends java.lang.Object
    implements Framer
    • Field Detail

      • closed

        private boolean closed
      • payload

        private byte[] payload
    • Method Detail

      • writePayload

        public void writePayload​(java.io.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