public static class BodyDeferringAsyncHandler.BodyDeferringInputStream extends FilterInputStream
in| Constructor and Description |
|---|
BodyDeferringAsyncHandler.BodyDeferringInputStream(Future<Response> future,
BodyDeferringAsyncHandler bdah,
InputStream in) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes the input stream, and "joins" (wait for complete execution
together with potential exception thrown) of the async request.
|
Response |
getAsapResponse()
Delegates to
BodyDeferringAsyncHandler.getResponse(). |
Response |
getLastResponse()
Delegates to
Future method. |
available, mark, markSupported, read, read, read, reset, skippublic BodyDeferringAsyncHandler.BodyDeferringInputStream(Future<Response> future, BodyDeferringAsyncHandler bdah, InputStream in)
public void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class FilterInputStreamIOExceptionpublic Response getAsapResponse() throws InterruptedException, IOException
BodyDeferringAsyncHandler.getResponse(). Will
blocks as long as headers arrives only. Might return
null. See
BodyDeferringAsyncHandler.getResponse() method for details.ResponseInterruptedExceptionIOExceptionpublic Response getLastResponse() throws InterruptedException, ExecutionException
Future#get() method. Will block
as long as complete response arrives.ResponseInterruptedExceptionExecutionExceptionCopyright © 2015. All rights reserved.