Package io.servicetalk.http.api
Interface FilterableStreamingHttpConnection
-
- All Superinterfaces:
AsyncCloseable,ListenableAsyncCloseable,StreamingHttpRequester,StreamingHttpRequestFactory
- All Known Subinterfaces:
FilterableReservedStreamingHttpConnection,FilterableStreamingHttpLoadBalancedConnection,ReservedStreamingHttpConnection,StreamingHttpConnection
- All Known Implementing Classes:
ReservedStreamingHttpConnectionFilter,StreamingHttpConnectionFilter
public interface FilterableStreamingHttpConnection extends StreamingHttpRequester
AStreamingHttpConnectionthat supported filtering.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description HttpConnectionContextconnectionContext()Get theHttpConnectionContext.<T> Publisher<? extends T>transportEventStream(HttpEventKey<T> eventKey)Returns aPublisherthat gives the current value of a transport event as well as subsequent changes to the event value as long as thePublisherSource.Subscriberhas expressed enough demand.-
Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable
closeAsync, closeAsyncGracefully
-
Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable
onClose
-
Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequester
executionContext, httpResponseFactory, request
-
-
-
-
Method Detail
-
connectionContext
HttpConnectionContext connectionContext()
Get theHttpConnectionContext.- Returns:
- the
HttpConnectionContext.
-
transportEventStream
<T> Publisher<? extends T> transportEventStream(HttpEventKey<T> eventKey)
Returns aPublisherthat gives the current value of a transport event as well as subsequent changes to the event value as long as thePublisherSource.Subscriberhas 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.
- Type Parameters:
T- Type of the event value.- Parameters:
eventKey- Name of the event to fetch.- Returns:
Publisherfor the event values.
-
-