Package io.servicetalk.http.api
Interface FilterableStreamingHttpClient
-
- All Superinterfaces:
AsyncCloseable,ListenableAsyncCloseable,StreamingHttpRequester,StreamingHttpRequestFactory
- All Known Subinterfaces:
StreamingHttpClient
- All Known Implementing Classes:
StreamingHttpClientFilter
public interface FilterableStreamingHttpClient extends StreamingHttpRequester
AStreamingHttpClientthat supports filtering.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Single<? extends FilterableReservedStreamingHttpConnection>reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData)Reserve aStreamingHttpConnectionbased on providedHttpRequestMetaData.-
Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable
closeAsync, closeAsyncGracefully
-
Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable
onClose
-
Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequester
executionContext, httpResponseFactory, request
-
-
-
-
Method Detail
-
reserveConnection
Single<? extends FilterableReservedStreamingHttpConnection> reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData)
Reserve aStreamingHttpConnectionbased on providedHttpRequestMetaData.- Parameters:
strategy-HttpExecutionStrategyto use.metaData- Allows the underlying layers to know whatStreamingHttpConnections are valid to reserve for futurerequestswith the sameHttpRequestMetaData. For example this may provide some insight into shard or other info.- Returns:
- a
Singlethat provides theReservedStreamingHttpConnectionupon completion.
-
-