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

A StreamingHttpConnection that supported filtering.

Method Summary

Modifier and Type	Method and Description
HttpConnectionContext	connectionContext() Get the HttpConnectionContext.
<T> Publisher<? extends T>	transportEventStream(HttpEventKey<T> eventKey) Returns a Publisher that gives the current value of a transport event as well as subsequent changes to the event value as long as the PublisherSource.Subscriber has expressed enough demand.

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, trace

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

onClose

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

closeAsync, closeAsyncGracefully

Method Detail

connectionContext

HttpConnectionContext connectionContext()

Get the HttpConnectionContext.

Returns:

the HttpConnectionContext.

transportEventStream

<T> Publisher<? extends T> transportEventStream(HttpEventKey<T> eventKey)

Returns a Publisher that gives the current value of a transport event as well as subsequent changes to the event value as long as the PublisherSource.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.

Type Parameters:

T - Type of the event value.

Parameters:

eventKey - Name of the event to fetch.

Returns:

Publisher for the event values.