public class StreamingHttpClientFilter extends java.lang.Object implements FilterableStreamingHttpClient
StreamingHttpClient that delegates all methods to a different StreamingHttpClient.| Modifier | Constructor and Description |
|---|---|
protected |
StreamingHttpClientFilter(FilterableStreamingHttpClient delegate)
Create a new instance.
|
protected StreamingHttpClientFilter(FilterableStreamingHttpClient delegate)
delegate - The FilterableStreamingHttpClient to delegate all calls to.public final Single<StreamingHttpResponse> request(HttpExecutionStrategy strategy, StreamingHttpRequest request)
StreamingHttpRequesterrequest using the specified strategy.request in interface StreamingHttpRequesterstrategy - HttpExecutionStrategy to use for executing the request.request - the request to send.public Single<? extends FilterableReservedStreamingHttpConnection> reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData)
FilterableStreamingHttpClientStreamingHttpConnection based on provided HttpRequestMetaData.reserveConnection in interface FilterableStreamingHttpClientstrategy - HttpExecutionStrategy to use.metaData - Allows the underlying layers to know what StreamingHttpConnections are valid to
reserve for future requests with the same HttpRequestMetaData.
For example this may provide some insight into shard or other info.Single that provides the ReservedStreamingHttpConnection upon completion.public HttpExecutionContext executionContext()
StreamingHttpRequesterHttpExecutionContext used during construction of this object.
Note that the ExecutionContext.ioExecutor() will not necessarily be associated with a specific thread
unless that was how this object was built.
executionContext in interface StreamingHttpRequesterHttpExecutionContext used during construction of this object.public StreamingHttpResponseFactory httpResponseFactory()
StreamingHttpRequesterStreamingHttpResponseFactory.httpResponseFactory in interface StreamingHttpRequesterStreamingHttpResponseFactory.public Completable onClose()
ListenableAsyncCloseableCompletable that is notified once the ListenableAsyncCloseable was closed.onClose in interface ListenableAsyncCloseableCompletable that is notified on close.public Completable closeAsync()
AsyncCloseablecloseAsync in interface AsyncCloseableCompletableSource that is notified once the close is complete.public Completable closeAsyncGracefully()
AsyncCloseableAsyncCloseable.closeAsync(), but attempts to cleanup state before
abruptly closing. This provides a hint that implementations can use to stop accepting new work and finish in
flight work. This method is implemented on a "best effort" basis and may be equivalent to AsyncCloseable.closeAsync().
Note: Implementations may or may not apply a timeout for this operation to complete, if a caller does not
want to wait indefinitely, and are unsure if the implementation applies a timeout, it is advisable to apply a
timeout and force a call to AsyncCloseable.closeAsync().
closeAsyncGracefully in interface AsyncCloseableCompletable that is notified once the close is complete.public StreamingHttpRequest newRequest(HttpRequestMethod method, java.lang.String requestTarget)
StreamingHttpRequestFactoryHttpRequestFactory.newRequest in interface StreamingHttpRequestFactorymethod - The HttpRequestMethod.requestTarget - The request target.HttpRequestFactory.public java.lang.String toString()
toString in class java.lang.Objectprotected final FilterableStreamingHttpClient delegate()
FilterableStreamingHttpClient this method delegates to.FilterableStreamingHttpClient this method delegates to.protected Single<StreamingHttpResponse> request(StreamingHttpRequester delegate, HttpExecutionStrategy strategy, StreamingHttpRequest request)
StreamingHttpRequester on
which to call StreamingHttpRequester.request(HttpExecutionStrategy, StreamingHttpRequest).delegate - The StreamingHttpRequester to delegate requests to.strategy - The HttpExecutionStrategy to use for executing the request.request - The request to delegate.