Class MessageStreamDecoderAdapter

    • Constructor Detail

      • MessageStreamDecoderAdapter

        public MessageStreamDecoderAdapter​(MessageStreamDecoder plug_decoder)
    • Method Detail

      • performStreamDecode

        public int performStreamDecode​(Transport transport,
                                       int max_bytes)
                                throws java.io.IOException
        Description copied from interface: MessageStreamDecoder
        Decode message stream from the given transport.
        Specified by:
        performStreamDecode in interface MessageStreamDecoder
        Parameters:
        transport - to decode from
        max_bytes - to decode/read from the stream
        Returns:
        number of bytes decoded
        Throws:
        java.io.IOException - on decoding error
      • getPercentDoneOfCurrentMessage

        public int getPercentDoneOfCurrentMessage()
        Description copied from interface: MessageStreamDecoder
        Get the percentage of the current message that has already been received (read from the transport).
        Specified by:
        getPercentDoneOfCurrentMessage in interface MessageStreamDecoder
        Returns:
        percentage complete (0-99), or -1 if no message is currently being received
      • removeDecodedMessages

        public Message[] removeDecodedMessages()
        Description copied from interface: MessageStreamDecoder
        Get the messages decoded from the transport, if any, from the last decode op.
        Specified by:
        removeDecodedMessages in interface MessageStreamDecoder
        Returns:
        decoded messages, or null if no new complete messages were decoded
      • getProtocolBytesDecoded

        public int getProtocolBytesDecoded()
        Description copied from interface: MessageStreamDecoder
        Get the number of protocol (overhead) bytes decoded from the transport, from the last decode op.
        Specified by:
        getProtocolBytesDecoded in interface MessageStreamDecoder
        Returns:
        number of protocol bytes recevied
      • getDataBytesDecoded

        public int getDataBytesDecoded()
        Description copied from interface: MessageStreamDecoder
        Get the number of (piece) data bytes decoded from the transport, from the last decode op.
        Specified by:
        getDataBytesDecoded in interface MessageStreamDecoder
        Returns:
        number of data bytes received
      • destroy

        public java.nio.ByteBuffer destroy()
        Description copied from interface: MessageStreamDecoder
        Destroy this decoder, i.e. perform cleanup.
        Specified by:
        destroy in interface MessageStreamDecoder
        Returns:
        any bytes already-read and still remaining within the decoder