org.ws4d.java.communication.protocol.http

Class HTTPInputStream

java.lang.Object

java.io.InputStream

org.ws4d.java.communication.RestoreableInputStream

org.ws4d.java.communication.protocol.http.HTTPInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, SupportsIsStreamClosed

public class HTTPInputStream
extends RestoreableInputStream
implements SupportsIsStreamClosed

HTTP input stream wrapper. This class wraps the input stream and controls the length of data read.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	chunked
protected org.ws4d.java.communication.protocol.http.HTTPChunkHeader	chunkedheader

Constructor Summary

Constructors

Constructor and Description
HTTPInputStream(java.io.InputStream in, boolean secure, java.lang.String encoding, long size) Creates a HTTP input stream.
HTTPInputStream(java.io.InputStream in, boolean secure, java.lang.String encoding, long size, Sync notify) Creates a HTTP input stream with synchronization.

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
int	discardPendingBytes() Discard pending bytes.
boolean	equals(java.lang.Object obj)
long	getCurrentSize()
java.lang.String	getEncoding() Returns the encoding for this stream.
int	hashCode()
boolean	isClosed()
boolean	isStreamClosed()
int	read()
int	read(byte[] b, int off, int len)
void	setRestoreBuffer(byte[] reBu, int startIndex, int length)
void	setRestoreBufferClone(byte[] reBu, int startIndex, int length)

Methods inherited from class java.io.InputStream

mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Field Detail

chunkedheader

protected org.ws4d.java.communication.protocol.http.HTTPChunkHeader chunkedheader

chunked

protected boolean chunked

Constructor Detail

HTTPInputStream

public HTTPInputStream(java.io.InputStream in,
                       boolean secure,
                       java.lang.String encoding,
                       long size)

Creates a HTTP input stream.

HTTPInputStream

public HTTPInputStream(java.io.InputStream in,
                       boolean secure,
                       java.lang.String encoding,
                       long size,
                       Sync notify)

Creates a HTTP input stream with synchronization.

Method Detail

setRestoreBuffer

public void setRestoreBuffer(byte[] reBu,
                             int startIndex,
                             int length)

Specified by:

setRestoreBuffer in class RestoreableInputStream

setRestoreBufferClone

public void setRestoreBufferClone(byte[] reBu,
                                  int startIndex,
                                  int length)

Specified by:

setRestoreBufferClone in class RestoreableInputStream

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException

isClosed

public boolean isClosed()
                 throws java.io.IOException

Throws:

java.io.IOException

read

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

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

discardPendingBytes

public int discardPendingBytes()
                        throws java.io.IOException

Discard pending bytes.

Returns:

-1 if there are potentially bytes left in the stream or the underlying stream is closed. Otherwise no byte is left in the stream and the returned value is the number of bytes that have been discarded.

Throws:

java.io.IOException

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

available

public int available()
              throws java.io.IOException

Overrides:

available in class java.io.InputStream

Throws:

java.io.IOException

getEncoding

public java.lang.String getEncoding()

Returns the encoding for this stream.

Returns:

the stream encoding.

getCurrentSize

public long getCurrentSize()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

isStreamClosed

public boolean isStreamClosed()

Specified by:

isStreamClosed in interface SupportsIsStreamClosed