public class FutureStreamResponseImpl extends FutureResponseImpl implements StreamResponse
FutureResponse
which wraps a StreamResponse
and so provide an async way to get notified about ready responsesFutureResponse.ResponseListener
response
DISCONNECT
Constructor and Description |
---|
FutureStreamResponseImpl() |
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. |
addListener, checkReady, getLines, getRetCode, isEndSession, isReady, removeListener, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getLines, getRetCode, isEndSession
public void setResponse(Response response)
StreamResponse
to wrap. If a non StreamResponse
is set this implementation will throw an IllegalArgumentException
setResponse
in class FutureResponseImpl
public InputStream getStream()
StreamResponse
InputStream
on every call. So once it is consumed there is no way to re-process it.getStream
in interface StreamResponse
Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.