Package fr.gouv.vitam.common.stream
This package concerns Common Stream handling as Helpers for common actions or MultipleInputStream multiplexer.
-
Class Summary Class Description BoundedByteBuffer Buffer with buffering allowing One Writer and Multiple Readers.ExactDigestValidatorInputStream Input stream that checks input stream digestExactSizeInputStream Input 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 LazySequenceInputStream ASequenceInputStream
-like implementation with lazy input stream iterator.MultiplePipedInputStream Generate multiples InputStreams from one to many using PipeMultiplexedStreamReader Reader for multiplexed streams.MultiplexedStreamWriter Write for multiplexed streams.PrependedMultiplexedInputStream Wrapper around a multiplexed stream to prepend it with a header entry.ProducerConsumerLock Producer-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 ImplementsAutoCloseable
- When closed, all locks are unlocked.SizedInputStream Input stream with read sizeStreamUtils This class supports Helpers on streams.VitamAsyncInputStream VitamAsyncInputStreamResponse This class implements a fake InputStream from a Response such that the response will be closed once the stream is closed itself.