Package com.predic8.membrane.core.http

Class Body

java.lang.Object

com.predic8.membrane.core.http.AbstractBody

com.predic8.membrane.core.http.Body

public class Body
extends AbstractBody

A message body (streaming, if possible). Use a subclass of ChunkedBody instead, if "Transfer-Encoding: chunked" is set on the input.

The "Transfer-Encoding" of the output is not determined by this class hierarchy, but by AbstractBodyTransferrer and its subclasses.

The caller is responsible to adjust the header accordingly, e.g. the fields Transfer-Encoding and Content-Length.

Field Summary

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

chunks, observers

Constructor Summary

Constructors

Constructor	Description
Body(byte[] content)
Body(InputStream in)
Body(InputStream in, long length)

Method Summary

Modifier and Type	Method	Description
void	discard()
int	getLength()	Warning: Calling this method will trigger reading the body from the client, disabling "streaming".
protected byte[]	getRawLocal()
protected void	readLocal()
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, getContentAsStream, getObservers, getRaw, getTrailer, hasRelevantObservers, hasTrailer, isRead, markAsRead, read, setTrailer, toString, wasStreamed, write

Methods inherited from class java.lang.Object

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

Constructor Details

Body

public Body(InputStream in)
     throws IOException

Throws:

IOException

Body

public Body(InputStream in,
 long length)
     throws IOException

Throws:

IOException

Body

public Body(byte[] content)

Method Details

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

writeAlreadyRead

protected void writeAlreadyRead(AbstractBodyTransferrer out)
                         throws IOException

Specified by:

writeAlreadyRead in class AbstractBody

Throws:

IOException

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

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

getRawLocal

protected byte[] getRawLocal()
                      throws IOException

Specified by:

getRawLocal in class AbstractBody

Throws:

IOException