This package concerns Common Stream handling as Helpers for common actions or MultipleInputStream multiplexer.
Class Summary Class Description BoundedByteBufferBuffer with buffering allowing One Writer and Multiple Readers. ExactDigestValidatorInputStreamInput stream that checks input stream digest ExactSizeInputStreamInput stream that checks input stream size (avoids premature EOF or invalid file size) This input stream guaranties that an exception occur BEFORE the last data byte is returned. ExtendedFileOutputStream MultiplePipedInputStreamGenerate multiples InputStreams from one to many using Pipe MultiplexedStreamReaderReader for multiplexed streams. MultiplexedStreamWriterWrite for multiplexed streams. PrependedMultiplexedInputStreamWrapper around a multiplexed stream to prepend it with a header entry. ProducerConsumerLockProducer-Consumer lock implementation : (https://en.wikipedia.org/wiki/Producer%E2%80%93consumer_problem) Inspired from https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/locks/Condition.html implementation Implements
AutoCloseable- When closed, all locks are unlocked.
SizedInputStreamInput stream with read size StreamUtilsThis class supports Helpers on streams. VitamAsyncInputStream VitamAsyncInputStreamResponseThis class implements a fake InputStream from a Response such that the response will be closed once the stream is closed itself.