Package io.servicetalk.http.api

Interface FilterableStreamingHttpLoadBalancedConnection

All Superinterfaces:

AsyncCloseable, AutoCloseable, FilterableReservedStreamingHttpConnection, FilterableStreamingHttpConnection, GracefulAutoCloseable, ListenableAsyncCloseable, LoadBalancedConnection, RequestConcurrencyController, ReservableRequestConcurrencyController, ReservedStreamingHttpConnection, ScoreSupplier, StreamingHttpConnection, StreamingHttpRequester, StreamingHttpRequestFactory

All Known Implementing Classes:

DelegatingFilterableStreamingHttpLoadBalancedConnection, HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection

public interface FilterableStreamingHttpLoadBalancedConnection
extends LoadBalancedConnection, ReservedStreamingHttpConnection

A FilterableStreamingHttpConnection that supported filtering and implements the LoadBalancedConnection contract.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.client.api.RequestConcurrencyController

RequestConcurrencyController.Result

Method Summary

Modifier and Type	Method	Description
default ReservedBlockingHttpConnection	asBlockingConnection()	Convert this StreamingHttpConnection to the BlockingHttpConnection API.
default ReservedBlockingStreamingHttpConnection	asBlockingStreamingConnection()	Convert this StreamingHttpConnection to the BlockingStreamingHttpConnection API.
default ReservedHttpConnection	asConnection()	Convert this StreamingHttpConnection to the HttpConnection API.
default Completable	releaseAsync()	Must be called (and subscribed to) to signify the reservation has completed after ReservableRequestConcurrencyController.tryReserve().

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

closeAsync, closeAsyncGracefully

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

connectionContext, transportEventStream

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

onClose, onClosing

Methods inherited from interface io.servicetalk.client.api.LoadBalancedConnection

requestFinished, tryRequest, tryReserve

Methods inherited from interface io.servicetalk.client.api.ScoreSupplier

score

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

close, closeGracefully, executionContext, httpResponseFactory, request

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

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

Method Details

asConnection

default ReservedHttpConnection asConnection()

Description copied from interface: StreamingHttpConnection

Convert this StreamingHttpConnection to the HttpConnection API.

This API is provided for convenience. It is recommended that filters are implemented using the StreamingHttpConnection asynchronous API for maximum portability.

Specified by:

asConnection in interface ReservedStreamingHttpConnection

Specified by:

asConnection in interface StreamingHttpConnection

Returns:

a HttpConnection representation of this StreamingHttpConnection.

asBlockingStreamingConnection

default ReservedBlockingStreamingHttpConnection asBlockingStreamingConnection()

Description copied from interface: StreamingHttpConnection

Convert this StreamingHttpConnection to the BlockingStreamingHttpConnection API.

This API is provided for convenience for a more familiar sequential programming model. It is recommended that filters are implemented using the StreamingHttpConnection asynchronous API for maximum portability.

Specified by:

asBlockingStreamingConnection in interface ReservedStreamingHttpConnection

Specified by:

asBlockingStreamingConnection in interface StreamingHttpConnection

Returns:

a BlockingStreamingHttpConnection representation of this StreamingHttpConnection.

asBlockingConnection

default ReservedBlockingHttpConnection asBlockingConnection()

Description copied from interface: StreamingHttpConnection

Convert this StreamingHttpConnection to the BlockingHttpConnection API.

This API is provided for convenience for a more familiar sequential programming model. It is recommended that filters are implemented using the StreamingHttpConnection asynchronous API for maximum portability.

Specified by:

asBlockingConnection in interface ReservedStreamingHttpConnection

Specified by:

asBlockingConnection in interface StreamingHttpConnection

Returns:

a BlockingHttpConnection representation of this StreamingHttpConnection.

releaseAsync

default Completable releaseAsync()

Description copied from interface: ReservableRequestConcurrencyController

Must be called (and subscribed to) to signify the reservation has completed after ReservableRequestConcurrencyController.tryReserve().

Specified by:

releaseAsync in interface FilterableReservedStreamingHttpConnection

Specified by:

releaseAsync in interface LoadBalancedConnection

Specified by:

releaseAsync in interface ReservableRequestConcurrencyController

Returns:

a Completable for the release.