Package io.servicetalk.http.api
Class StreamingHttpConnectionFilter
- java.lang.Object
-
- io.servicetalk.http.api.StreamingHttpConnectionFilter
-
- All Implemented Interfaces:
AsyncCloseable
,ListenableAsyncCloseable
,FilterableStreamingHttpConnection
,StreamingHttpRequester
,StreamingHttpRequestFactory
public class StreamingHttpConnectionFilter extends java.lang.Object implements FilterableStreamingHttpConnection
AStreamingHttpConnection
that delegates all methods to a differentStreamingHttpConnection
.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
StreamingHttpConnectionFilter(FilterableStreamingHttpConnection delegate)
Create a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Completable
closeAsync()
Used to close/shutdown a resource.Completable
closeAsyncGracefully()
Used to close/shutdown a resource, similar toAsyncCloseable.closeAsync()
, but attempts to cleanup state before abruptly closing.HttpConnectionContext
connectionContext()
Get theHttpConnectionContext
.protected FilterableStreamingHttpConnection
delegate()
Get theFilterableStreamingHttpConnection
this method delegates to.HttpExecutionContext
executionContext()
Get theHttpExecutionContext
used during construction of this object.StreamingHttpResponseFactory
httpResponseFactory()
Get aStreamingHttpResponseFactory
.StreamingHttpRequest
newRequest(HttpRequestMethod method, java.lang.String requestTarget)
Create a newHttpRequestFactory
.Completable
onClose()
Returns aCompletable
that is notified once theListenableAsyncCloseable
was closed.Single<StreamingHttpResponse>
request(HttpExecutionStrategy strategy, StreamingHttpRequest request)
Send arequest
using the specifiedstrategy
.java.lang.String
toString()
<T> Publisher<? extends T>
transportEventStream(HttpEventKey<T> eventKey)
Returns aPublisher
that gives the current value of a transport event as well as subsequent changes to the event value as long as thePublisherSource.Subscriber
has expressed enough demand.
-
-
-
Constructor Detail
-
StreamingHttpConnectionFilter
protected StreamingHttpConnectionFilter(FilterableStreamingHttpConnection delegate)
Create a new instance.- Parameters:
delegate
- TheFilterableStreamingHttpConnection
to delegate all calls to.
-
-
Method Detail
-
request
public Single<StreamingHttpResponse> request(HttpExecutionStrategy strategy, StreamingHttpRequest request)
Description copied from interface:StreamingHttpRequester
Send arequest
using the specifiedstrategy
.- Specified by:
request
in interfaceStreamingHttpRequester
- Parameters:
strategy
-HttpExecutionStrategy
to use for executing the request.request
- the request to send.- Returns:
- The response.
-
connectionContext
public HttpConnectionContext connectionContext()
Description copied from interface:FilterableStreamingHttpConnection
Get theHttpConnectionContext
.- Specified by:
connectionContext
in interfaceFilterableStreamingHttpConnection
- Returns:
- the
HttpConnectionContext
.
-
transportEventStream
public <T> Publisher<? extends T> transportEventStream(HttpEventKey<T> eventKey)
Description copied from interface:FilterableStreamingHttpConnection
Returns aPublisher
that gives the current value of a transport event as well as subsequent changes to the event value as long as thePublisherSource.Subscriber
has expressed enough demand.This is designed for events produced by the transport, and consumed by filters interested in transport behavior which is not directly involved in the data path.
- Specified by:
transportEventStream
in interfaceFilterableStreamingHttpConnection
- Type Parameters:
T
- Type of the event value.- Parameters:
eventKey
- Name of the event to fetch.- Returns:
Publisher
for the event values.
-
executionContext
public HttpExecutionContext executionContext()
Description copied from interface:StreamingHttpRequester
Get theHttpExecutionContext
used during construction of this object.Note that the
ExecutionContext.ioExecutor()
will not necessarily be associated with a specific thread unless that was how this object was built.- Specified by:
executionContext
in interfaceStreamingHttpRequester
- Returns:
- the
HttpExecutionContext
used during construction of this object.
-
httpResponseFactory
public StreamingHttpResponseFactory httpResponseFactory()
Description copied from interface:StreamingHttpRequester
Get aStreamingHttpResponseFactory
.- Specified by:
httpResponseFactory
in interfaceStreamingHttpRequester
- Returns:
- a
StreamingHttpResponseFactory
.
-
onClose
public Completable onClose()
Description copied from interface:ListenableAsyncCloseable
Returns aCompletable
that is notified once theListenableAsyncCloseable
was closed.- Specified by:
onClose
in interfaceListenableAsyncCloseable
- Returns:
- the
Completable
that is notified on close.
-
closeAsync
public Completable closeAsync()
Description copied from interface:AsyncCloseable
Used to close/shutdown a resource.- Specified by:
closeAsync
in interfaceAsyncCloseable
- Returns:
- A
Completable
that is notified once the close is complete.
-
closeAsyncGracefully
public Completable closeAsyncGracefully()
Description copied from interface:AsyncCloseable
Used to close/shutdown a resource, similar toAsyncCloseable.closeAsync()
, but attempts to cleanup state before abruptly closing. This provides a hint that implementations can use to stop accepting new work and finish in flight work. This method is implemented on a "best effort" basis and may be equivalent toAsyncCloseable.closeAsync()
.Note: Implementations may or may not apply a timeout for this operation to complete, if a caller does not want to wait indefinitely, and are unsure if the implementation applies a timeout, it is advisable to apply a timeout and force a call to
AsyncCloseable.closeAsync()
.- Specified by:
closeAsyncGracefully
in interfaceAsyncCloseable
- Returns:
- A
Completable
that is notified once the close is complete.
-
newRequest
public final StreamingHttpRequest newRequest(HttpRequestMethod method, java.lang.String requestTarget)
Description copied from interface:StreamingHttpRequestFactory
Create a newHttpRequestFactory
.- Specified by:
newRequest
in interfaceStreamingHttpRequestFactory
- Parameters:
method
- TheHttpRequestMethod
.requestTarget
- The request target.- Returns:
- a new
HttpRequestFactory
.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
delegate
protected final FilterableStreamingHttpConnection delegate()
Get theFilterableStreamingHttpConnection
this method delegates to.- Returns:
- the
FilterableStreamingHttpConnection
this method delegates to.
-
-