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:

java.io.Closeable, java.lang.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

Constructors

Constructor	Description
PrependedMultiplexedInputStream(java.io.InputStream firstEntryStream, long firstEntrySize, java.io.InputStream multiplexedInputStream, long multiplexedInputStreamSize)

Method Summary

Modifier and Type	Method	Description
long	size()

Methods inherited from class org.apache.commons.io.input.ProxyInputStream

afterRead, available, beforeRead, close, handleIOException, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, transferTo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrependedMultiplexedInputStream

public PrependedMultiplexedInputStream(java.io.InputStream firstEntryStream,
                                       long firstEntrySize,
                                       java.io.InputStream multiplexedInputStream,
                                       long multiplexedInputStreamSize)
                                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

size

public long size()