FilterableStreamingHttpConnection

All Superinterfaces:: AsyncCloseable, AutoCloseable, GracefulAutoCloseable, ListenableAsyncCloseable, StreamingHttpRequester, StreamingHttpRequestFactory

All Known Subinterfaces:: FilterableReservedStreamingHttpConnection, FilterableStreamingHttpLoadBalancedConnection, ReservedStreamingHttpConnection, StreamingHttpConnection

All Known Implementing Classes:: DelegatingFilterableStreamingHttpLoadBalancedConnection, HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection, ReservedStreamingHttpConnectionFilter, StreamingHttpConnectionFilter

public interface FilterableStreamingHttpConnection extends StreamingHttpRequester

A StreamingHttpConnection that supported filtering.

Method Summary

Modifier and Type

Method

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.concurrent.api.AsyncCloseable
closeAsync, closeAsyncGracefully

Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable
onClose, onClosing

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequester
close, closeGracefully, executionContext, httpResponseFactory, request

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequestFactory
connect, delete, get, head, newRequest, options, patch, post, put, trace

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