Package fr.gouv.vitam.common.stream
package fr.gouv.vitam.common.stream
This package concerns Common Stream handling as Helpers for common actions or MultipleInputStream multiplexer.
-
ClassDescriptionBuffer with buffering allowing One Writer and Multiple Readers.Input stream that checks input stream digestInput 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.A
SequenceInputStream
-like implementation with lazy input stream iterator.Generate multiples InputStreams from one to many using PipeReader for multiplexed streams.Write for multiplexed streams.Wrapper around a multiplexed stream to prepend it with a header entry.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.Input stream with read sizeThis class supports Helpers on streams.This class implements a fake InputStream from a Response such that the response will be closed once the stream is closed itself.