Package com.predic8.membrane.core.http

Class ChunkedBody

java.lang.Object

com.predic8.membrane.core.http.AbstractBody

com.predic8.membrane.core.http.ChunkedBody

public class ChunkedBody
extends AbstractBody

Reads the body with "Transfer-Encoding: chunked".

See ChunkedBodyTransferrer for writing a body using chunks.

Field Summary

Fields inherited from class com.predic8.membrane.core.http.AbstractBody

chunks, observers

Constructor Summary

Constructors

Constructor	Description
ChunkedBody(InputStream in)

Method Summary

Modifier and Type	Method	Description
void	discard()
InputStream	getContentAsStream()
int	getLength()	Warning: Calling this method will trigger reading the body from the client, disabling "streaming".
protected int	getRawLength()
protected byte[]	getRawLocal()
Header	getTrailer()
boolean	hasTrailer()
boolean	isRead()
protected void	markAsRead()
void	read()
static int	readChunkSize(InputStream in)
protected void	readLocal()
boolean	setTrailer(Header trailer)
void	write(AbstractBodyTransferrer out, boolean retainCopy)
protected void	writeAlreadyRead(AbstractBodyTransferrer out)
protected void	writeNotRead(AbstractBodyTransferrer out)
protected void	writeStreamed(AbstractBodyTransferrer out)	Is called when there are no observers that need to read the body.

Methods inherited from class com.predic8.membrane.core.http.AbstractBody

getContent, getObservers, getRaw, hasRelevantObservers, toString, wasStreamed

Methods inherited from class java.lang.Object

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

Constructor Details

ChunkedBody

public ChunkedBody(InputStream in)

Method Details

readChunkSize

public static int readChunkSize(InputStream in)
                         throws IOException

Throws:

IOException

read

public void read()
          throws IOException

Overrides:

read in class AbstractBody

Throws:

IOException

write

public void write(AbstractBodyTransferrer out,
 boolean retainCopy)
           throws IOException

Overrides:

write in class AbstractBody

Throws:

IOException

markAsRead

protected void markAsRead()

Overrides:

markAsRead in class AbstractBody

readLocal

protected void readLocal()
                  throws IOException

Specified by:

readLocal in class AbstractBody

Throws:

IOException

discard

public void discard()
             throws IOException

Overrides:

discard in class AbstractBody

Throws:

IOException

getContentAsStream

public InputStream getContentAsStream()

Overrides:

getContentAsStream in class AbstractBody

writeNotRead

protected void writeNotRead(AbstractBodyTransferrer out)
                     throws IOException

Specified by:

writeNotRead in class AbstractBody

Throws:

IOException

writeStreamed

protected void writeStreamed(AbstractBodyTransferrer out)
                      throws IOException

Description copied from class: AbstractBody

Is called when there are no observers that need to read the body. Streams the body without reading it

Specified by:

writeStreamed in class AbstractBody

Throws:

IOException

getRawLength

protected int getRawLength()
                    throws IOException

Throws:

IOException

getRawLocal

protected byte[] getRawLocal()
                      throws IOException

Specified by:

getRawLocal in class AbstractBody

Throws:

IOException

writeAlreadyRead

protected void writeAlreadyRead(AbstractBodyTransferrer out)
                         throws IOException

Specified by:

writeAlreadyRead in class AbstractBody

Throws:

IOException

getLength

public int getLength()
              throws IOException

Description copied from class: AbstractBody

Warning: Calling this method will trigger reading the body from the client, disabling "streaming". Use AbstractBody.isRead() to determine wether the body already has been read, if necessary.

Overrides:

getLength in class AbstractBody

Returns:

the length of the return value of AbstractBody.getContent()

Throws:

IOException

isRead

public boolean isRead()

Overrides:

isRead in class AbstractBody

hasTrailer

public boolean hasTrailer()

Overrides:

hasTrailer in class AbstractBody

getTrailer

public Header getTrailer()

Overrides:

getTrailer in class AbstractBody

setTrailer

public boolean setTrailer(Header trailer)

Overrides:

setTrailer in class AbstractBody

Returns:

true, when the body supports trailers and the trailer was therefore set.