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
ConstructorsModifierConstructorDescriptionprotected
Create a new instance. -
Method Summary
Modifier and TypeMethodDescriptionprotected final FilterableReservedStreamingHttpConnection
delegate()
Get theFilterableReservedStreamingHttpConnection
this method delegates to.Releases this reservedFilterableStreamingHttpConnection
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
-
Constructor Details
-
ReservedStreamingHttpConnectionFilter
Create a new instance.- Parameters:
delegate
- TheFilterableReservedStreamingHttpConnection
to delegate all calls to
-
-
Method Details
-
releaseAsync
Description copied from interface:FilterableReservedStreamingHttpConnection
Releases this reservedFilterableStreamingHttpConnection
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 interfaceFilterableReservedStreamingHttpConnection
- Returns:
- the
Completable
that is notified on releaseAsync.
-
delegate
Get theFilterableReservedStreamingHttpConnection
this method delegates to.- Overrides:
delegate
in classStreamingHttpConnectionFilter
- Returns:
- the
FilterableReservedStreamingHttpConnection
this method delegates to.
-