Package io.servicetalk.http.api

Class ReservedStreamingHttpConnectionFilter

java.lang.Object

io.servicetalk.http.api.StreamingHttpConnectionFilter

io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter

All Implemented Interfaces:

AsyncCloseable, ListenableAsyncCloseable, FilterableReservedStreamingHttpConnection, FilterableStreamingHttpConnection, StreamingHttpRequester, StreamingHttpRequestFactory

public class ReservedStreamingHttpConnectionFilter
extends StreamingHttpConnectionFilter
implements FilterableReservedStreamingHttpConnection

A ReservedStreamingHttpConnectionFilter that delegates all methods to a different ReservedStreamingHttpConnectionFilter.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReservedStreamingHttpConnectionFilter(FilterableReservedStreamingHttpConnection delegate)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
protected final FilterableReservedStreamingHttpConnection	delegate()	Get the FilterableReservedStreamingHttpConnection this method delegates to.
Completable	releaseAsync()	Releases this reserved FilterableStreamingHttpConnection to be used for subsequent requests.

Methods inherited from class io.servicetalk.http.api.StreamingHttpConnectionFilter

closeAsync, closeAsyncGracefully, connectionContext, executionContext, httpResponseFactory, newRequest, onClose, onClosing, request, toString, transportEventStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

Constructor Details

ReservedStreamingHttpConnectionFilter

protected ReservedStreamingHttpConnectionFilter(FilterableReservedStreamingHttpConnection delegate)

Create a new instance.

Parameters:

delegate - The FilterableReservedStreamingHttpConnection to delegate all calls to

Method Details

releaseAsync

public Completable releaseAsync()

Description copied from interface: FilterableReservedStreamingHttpConnection

Releases this reserved FilterableStreamingHttpConnection to be used for subsequent requests. This method must be idempotent, i.e. calling multiple times must not have side-effects.

Specified by:

releaseAsync in interface FilterableReservedStreamingHttpConnection

Returns:

the Completable that is notified on releaseAsync.

delegate

protected final FilterableReservedStreamingHttpConnection delegate()

Get the FilterableReservedStreamingHttpConnection this method delegates to.

Overrides:

delegate in class StreamingHttpConnectionFilter

Returns:

the FilterableReservedStreamingHttpConnection this method delegates to.