Package io.servicetalk.http.api

Interface HttpConnection

All Superinterfaces:

AsyncCloseable, AutoCloseable, GracefulAutoCloseable, HttpRequester, HttpRequestFactory, ListenableAsyncCloseable

All Known Subinterfaces:

ReservedHttpConnection

public interface HttpConnection
extends HttpRequester

Represents a single fixed connection to a HTTP server.

Method Summary

Modifier and Type	Method	Description
default BlockingHttpConnection	asBlockingConnection()	Convert this HttpConnection to the BlockingHttpConnection API.
default BlockingStreamingHttpConnection	asBlockingStreamingConnection()	Convert this HttpConnection to the BlockingStreamingHttpConnection API.
StreamingHttpConnection	asStreamingConnection()	Convert this HttpConnection to the StreamingHttpConnection API.
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.http.api.HttpRequester

close, closeGracefully, executionContext, httpResponseFactory, request

Methods inherited from interface io.servicetalk.http.api.HttpRequestFactory

connect, delete, get, head, newRequest, options, patch, post, put, trace

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

onClose, onClosing

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.

asStreamingConnection

StreamingHttpConnection asStreamingConnection()

Convert this HttpConnection to the StreamingHttpConnection API.

Returns:

a StreamingHttpConnection representation of this HttpConnection.

asBlockingStreamingConnection

default BlockingStreamingHttpConnection asBlockingStreamingConnection()

Convert this HttpConnection to the BlockingStreamingHttpConnection API.

Returns:

a BlockingStreamingHttpConnection representation of this HttpConnection.

asBlockingConnection

default BlockingHttpConnection asBlockingConnection()

Convert this HttpConnection to the BlockingHttpConnection API.

Returns:

a BlockingHttpConnection representation of this HttpConnection.