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

Description

Single<? extends FilterableReservedStreamingHttpConnection>

reserveConnection(HttpRequestMetaData metaData)

Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.

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

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequestFactory
connect, delete, get, head, newRequest, options, patch, post, put, trace

Method Details
- reserveConnection
  
  Single<? extends FilterableReservedStreamingHttpConnection> reserveConnection(HttpRequestMetaData metaData)
  
  Reserve a StreamingHttpConnection based on provided HttpRequestMetaData.
  
  Parameters:
  
  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 a FilterableReservedStreamingHttpConnection upon completion.