Class AbstractStreamDecoder.BufferedStream

  • Enclosing class:
    AbstractStreamDecoder<M,​MT extends java.lang.Enum<MT>,​ST extends java.lang.Enum<ST>>

    public final class AbstractStreamDecoder.BufferedStream
    extends java.lang.Object
    This class avoids locking which gains the performance of this decoder.
    • Field Detail

      • buffer

        private byte[] buffer
      • count

        private int count
      • positionByteBuffer

        private int positionByteBuffer
      • isNewLine

        private boolean isNewLine
    • Constructor Detail

      • BufferedStream

        BufferedStream​(int capacity)
    • Method Detail

      • getPositionByteBuffer

        public int getPositionByteBuffer()
      • setPositionByteBuffer

        public void setPositionByteBuffer​(int positionByteBuffer)
      • write

        public void write​(java.nio.ByteBuffer bb,
                          int position,
                          int length)
      • clear

        public void clear()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • isEmpty

        private boolean isEmpty()
      • ensureCapacity

        private void ensureCapacity​(int addCapacity)
      • printExistingLine

        void printExistingLine()
      • isJvmError

        private boolean isJvmError​(java.lang.String line)