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

A StreamingHttpClient that supports filtering.

Method Summary

Modifier and Type	Method and Description
Single<? extends FilterableReservedStreamingHttpConnection>	reserveConnection(HttpExecutionStrategy strategy, HttpRequestMetaData metaData) Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequester

executionContext, httpResponseFactory, request

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequestFactory

connect, delete, get, head, newRequest, options, patch, post, trace

Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable

onClose

Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable

closeAsync, closeAsyncGracefully

Method Detail

reserveConnection

Single<? extends FilterableReservedStreamingHttpConnection> reserveConnection(HttpExecutionStrategy strategy,
                                                                              HttpRequestMetaData metaData)

Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.

Parameters:

strategy - 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.

Returns:

a Single that provides the ReservedStreamingHttpConnection upon completion.