Package fr.gouv.vitam.common.stream
Class PrependedMultiplexedInputStream
java.lang.Object
java.io.InputStream
java.io.FilterInputStream
org.apache.commons.io.input.ProxyInputStream
fr.gouv.vitam.common.stream.PrependedMultiplexedInputStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class PrependedMultiplexedInputStream
extends org.apache.commons.io.input.ProxyInputStream
Wrapper around a multiplexed stream to prepend it with a header entry.
Initial stream format is "SIZE1(long)DATA1(raw)SIZE2(long)DATA2(raw)..."
Target stream format is "SIZE0(long)DATA0(raw)SIZE1(long)DATA1(raw)SIZE2(long)DATA2(raw)..."
-
Field Summary
Fields inherited from class java.io.FilterInputStream
in
-
Constructor Summary
ConstructorsConstructorDescriptionPrependedMultiplexedInputStream
(InputStream firstEntryStream, long firstEntrySize, InputStream multiplexedInputStream, long multiplexedInputStreamSize) -
Method Summary
Methods inherited from class org.apache.commons.io.input.ProxyInputStream
afterRead, available, beforeRead, close, handleIOException, mark, markSupported, read, read, read, reset, skip, unwrap
Methods inherited from class java.io.InputStream
nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo
-
Constructor Details
-
PrependedMultiplexedInputStream
public PrependedMultiplexedInputStream(InputStream firstEntryStream, long firstEntrySize, InputStream multiplexedInputStream, long multiplexedInputStreamSize) throws IOException - Throws:
IOException
-
-
Method Details
-
size
public long size()
-