Package io.servicetalk.http.api
Interface FilterableStreamingHttpClient
- All Superinterfaces:
AsyncCloseable
,ListenableAsyncCloseable
,StreamingHttpRequester
,StreamingHttpRequestFactory
- All Known Subinterfaces:
StreamingHttpClient
- All Known Implementing Classes:
StreamingHttpClientFilter
A
StreamingHttpClient
that supports filtering.-
Method Summary
Modifier and TypeMethodDescriptionSingle<? extends FilterableReservedStreamingHttpConnection>
reserveConnection
(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, onClosing
Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequester
executionContext, httpResponseFactory, request
-
Method Details
-
reserveConnection
Single<? extends FilterableReservedStreamingHttpConnection> reserveConnection(HttpRequestMetaData metaData) Reserve aStreamingHttpConnection
based on providedHttpRequestMetaData
.- Parameters:
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 aFilterableReservedStreamingHttpConnection
upon completion.
-