Package com.predic8.membrane.core.http

Class BodyCollectingMessageObserver

java.lang.Object

com.predic8.membrane.core.http.BodyCollectingMessageObserver

All Implemented Interfaces:

MessageObserver

public abstract class BodyCollectingMessageObserver
extends Object
implements MessageObserver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	BodyCollectingMessageObserver.Strategy

Constructor Summary

Constructors

Constructor	Description
BodyCollectingMessageObserver(BodyCollectingMessageObserver.Strategy strategy, long limit)

Method Summary

Modifier and Type	Method	Description
void	bodyChunk(byte[] buffer, int offset, int length)	Observes a piece of the body.
void	bodyChunk(Chunk chunk)	Observes a piece of the body.
AbstractBody	getBody(AbstractBody body)
boolean	isTruncated()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.predic8.membrane.core.http.MessageObserver

bodyComplete, bodyRequested

Constructor Details

BodyCollectingMessageObserver

public BodyCollectingMessageObserver(BodyCollectingMessageObserver.Strategy strategy,
 long limit)

Method Details

bodyChunk

public void bodyChunk(byte[] buffer,
 int offset,
 int length)

Description copied from interface: MessageObserver

Observes a piece of the body. Note that the buffer content may change after the method completes.

Specified by:

bodyChunk in interface MessageObserver

bodyChunk

public void bodyChunk(Chunk chunk)

Description copied from interface: MessageObserver

Observes a piece of the body.

Specified by:

bodyChunk in interface MessageObserver

getBody

public AbstractBody getBody(AbstractBody body)
                     throws IOException

Throws:

IOException

isTruncated

public boolean isTruncated()