Class AbstractSharedBuffer

    • Field Detail

      • lock

        final java.util.concurrent.locks.ReentrantLock lock
      • condition

        final java.util.concurrent.locks.Condition condition
      • endStream

        volatile boolean endStream
      • aborted

        volatile boolean aborted
    • Constructor Detail

      • AbstractSharedBuffer

        public AbstractSharedBuffer​(java.util.concurrent.locks.ReentrantLock lock,
                                    int initialBufferSize)
    • Method Detail

      • hasData

        public boolean hasData()
        Description copied from class: ExpandableBuffer
        Determines if the buffer contains data.

        Sets the mode to output.

        Overrides:
        hasData in class ExpandableBuffer
        Returns:
        true if there is data in the buffer, false otherwise.
      • length

        public int length()
        Description copied from class: ExpandableBuffer
        Returns the length of this buffer.

        Sets the mode to output.

        Overrides:
        length in class ExpandableBuffer
        Returns:
        buffer length.
      • abort

        public void abort()
      • reset

        public void reset()
      • isEndStream

        public boolean isEndStream()