Package de.undercouch.bson4jackson.io

Class BoundedInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

de.undercouch.bson4jackson.io.BoundedInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class BoundedInputStream
extends FilterInputStream

Input stream that bounds an underlying input stream to a particular size. This class is not thread-safe.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	count	The number of bytes read so far
protected boolean	eof	Whether the end of the underlying stream has been reached
protected int	mark	A marked position
protected final int	size	The stream's size

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
BoundedInputStream(InputStream in, int size)	Wraps another stream by this one

Method Summary

Modifier and Type	Method	Description
int	available()
void	mark(int readlimit)
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
void	reset()
long	skip(long n)

Methods inherited from class java.io.FilterInputStream

close, markSupported

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Field Details

size

protected final int size

The stream's size

count

protected int count

The number of bytes read so far

eof

protected boolean eof

Whether the end of the underlying stream has been reached

mark

protected int mark

A marked position

Constructor Details

BoundedInputStream

public BoundedInputStream(InputStream in,
 int size)

Wraps another stream by this one

Parameters:

in - the stream to wrap

size - the stream's size

Method Details

read

public int read()
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class FilterInputStream

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class FilterInputStream

Throws:

IOException

mark

public void mark(int readlimit)

Overrides:

mark in class FilterInputStream

reset

public void reset()
           throws IOException

Overrides:

reset in class FilterInputStream

Throws:

IOException