net.noderunner.http

Class LimitedInputStream

java.lang.Object

java.io.InputStream

net.noderunner.http.LimitedInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class LimitedInputStream
extends InputStream

An InputStream wrapper which allows only a certain number of bytes to be read. This is used in conjunction reading from HTTP requests or responses with supplied Content-Length headers. This stream is unsynchronized.

Author:

Elias Ross

See Also:

LimitedOutputStream

Constructor Summary

Constructors

Constructor and Description
LimitedInputStream(InputStream stream, int lengthLimit) Constructs a limited input stream.

Method Summary

Methods

Modifier and Type	Method and Description
int	available() Calls the wrapped stream.
void	close() Closes the underlying input stream.
void	mark(int readlimit) Calls the wrapped stream.
boolean	markSupported() Calls the wrapped stream.
int	read() Reads and returns a single byte from this input stream, or -1 if end of file or the read limit has been encountered.
int	read(byte[] b, int off, int len) Reads up to len bytes of data from the input stream into an array of bytes, possibly less if the read limit is reached.
void	reset() Calls the wrapped stream.
String	toString() Returns a debug string.

Methods inherited from class java.io.InputStream

read, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

LimitedInputStream

public LimitedInputStream(InputStream stream,
                  int lengthLimit)

Constructs a limited input stream.

Parameters:

stream - Must be non-null.

lengthLimit - limit of bytes of input.

Method Detail

close

public void close()
           throws IOException

Closes the underlying input stream.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

read

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

Reads up to len bytes of data from the input stream into an array of bytes, possibly less if the read limit is reached.

Overrides:

read in class InputStream

Throws:

IOException

available

public int available()
              throws IOException

Calls the wrapped stream.

Overrides:

available in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Calls the wrapped stream.

Overrides:

markSupported in class InputStream

reset

public void reset()
           throws IOException

Calls the wrapped stream.

Overrides:

reset in class InputStream

Throws:

IOException

mark

public void mark(int readlimit)

Calls the wrapped stream.

Overrides:

mark in class InputStream

read

public int read()
         throws IOException

Reads and returns a single byte from this input stream, or -1 if end of file or the read limit has been encountered.

Specified by:

read in class InputStream

Throws:

IOException

toString

public String toString()

Returns a debug string.

Overrides:

toString in class Object