org.apache.james.protocols.api.future

Class FutureStreamResponseImpl

java.lang.Object

org.apache.james.protocols.api.future.FutureResponseImpl

org.apache.james.protocols.api.future.FutureStreamResponseImpl

All Implemented Interfaces:

FutureResponse, Response, StreamResponse

public class FutureStreamResponseImpl
extends FutureResponseImpl
implements StreamResponse

Special FutureResponse which wraps a StreamResponse and so provide an async way to get notified about ready responses

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.james.protocols.api.future.FutureResponse

FutureResponse.ResponseListener

Field Summary

Fields inherited from class org.apache.james.protocols.api.future.FutureResponseImpl

response

Fields inherited from interface org.apache.james.protocols.api.Response

DISCONNECT

Constructor Summary

Constructors

Constructor and Description
FutureStreamResponseImpl()

Method Summary

Methods

Modifier and Type	Method and Description
InputStream	getStream() Return the stream which needs to get written to the remote peer.
void	setResponse(Response response) Set the StreamResponse to wrap.

Methods inherited from class org.apache.james.protocols.api.future.FutureResponseImpl

addListener, checkReady, getLines, getRetCode, isEndSession, isReady, removeListener, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.james.protocols.api.Response

getLines, getRetCode, isEndSession

Constructor Detail

FutureStreamResponseImpl

public FutureStreamResponseImpl()

Method Detail

setResponse

public void setResponse(Response response)

Set the StreamResponse to wrap. If a non StreamResponse is set this implementation will throw an IllegalArgumentException

Overrides:

setResponse in class FutureResponseImpl

getStream

public InputStream getStream()

Description copied from interface: StreamResponse

Return the stream which needs to get written to the remote peer. This method should only be called one time (when the data is written to the client) as it returns the same InputStream on every call. So once it is consumed there is no way to re-process it.

Specified by:

getStream in interface StreamResponse

Returns:

stream