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
AStreamingHttpClient
that supports filtering.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Single<? extends FilterableReservedStreamingHttpConnection>
reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData)
Reserve aStreamingHttpConnection
based 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 aStreamingHttpConnection
based on providedHttpRequestMetaData
.- Parameters:
strategy
-HttpExecutionStrategy
to use.metaData
- Allows the underlying layers to know whatStreamingHttpConnection
s are valid to reserve for futurerequests
with the sameHttpRequestMetaData
. For example this may provide some insight into shard or other info.- Returns:
- a
Single
that provides theReservedStreamingHttpConnection
upon completion.
-
-