Package net.i2p.util
Class LookaheadInputStream
java.lang.Object
java.io.InputStream
java.io.FilterInputStream
net.i2p.util.LookaheadInputStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class LookaheadInputStream extends FilterInputStream
Simple lookahead buffer to keep the last K bytes in reserve,
configured to easily be reused. Currently only used by the
ResettableGZIPInputStream.
-
Field Summary
-
Constructor Summary
Constructors Constructor Description LookaheadInputStream(int lookaheadSize)
Configure a stream that hides a number of bytes from the reader. -
Method Summary
Modifier and Type Method Description boolean
getEOFReached()
byte[]
getFooter()
Grab the lookahead footer.void
initialize(InputStream src)
Start the LookaheadInputStream with the given input stream.int
read()
int
read(byte[] buf, int off, int len)
long
skip(long n)
Methods inherited from class java.io.FilterInputStream
available, close, mark, markSupported, read, reset
Methods inherited from class java.io.InputStream
nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo
-
Constructor Details
-
LookaheadInputStream
public LookaheadInputStream(int lookaheadSize)Configure a stream that hides a number of bytes from the reader. The last n bytes will never be available from read(), they can only be obtained from getFooter(). initialize() MUST be called before doing any read() calls.- Parameters:
lookaheadSize
- how many bytes to hide
-
-
Method Details
-
getEOFReached
public boolean getEOFReached() -
initialize
Start the LookaheadInputStream with the given input stream. Resets everything if the LookaheadInputStream was previously used. WARNING - blocking until lookaheadSize bytes are read!- Throws:
IOException
- if less than lookaheadSize bytes could be read.
-
read
- Overrides:
read
in classFilterInputStream
- Throws:
IOException
-
read
- Overrides:
read
in classFilterInputStream
- Throws:
IOException
-
getFooter
public byte[] getFooter()Grab the lookahead footer. This will be of size lookaheadsize given in constructor. The last byte received will be in the last byte of the array. -
skip
- Overrides:
skip
in classFilterInputStream
- Throws:
IOException
- Since:
- 0.9.33
-