Package io.servicetalk.http.api

Interface BlockingHttpConnection

All Superinterfaces:

AutoCloseable, BlockingHttpRequester, GracefulAutoCloseable, HttpRequestFactory

All Known Subinterfaces:

ReservedBlockingHttpConnection

public interface BlockingHttpConnection
extends BlockingHttpRequester

The equivalent of HttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.

Method Summary

Modifier and Type	Method	Description
default BlockingStreamingHttpConnection	asBlockingStreamingConnection()	Convert this BlockingHttpConnection to the BlockingStreamingHttpConnection API.
default HttpConnection	asConnection()	Convert this BlockingHttpConnection to the HttpConnection API.
StreamingHttpConnection	asStreamingConnection()	Convert this BlockingHttpConnection to the StreamingHttpConnection API.
HttpConnectionContext	connectionContext()	Get the HttpConnectionContext.
<T> BlockingIterable<? extends T>	transportEventIterable(HttpEventKey<T> eventKey)	Returns a BlockingIterable that gives the current value of the setting as well as subsequent changes to the setting value as long as the PublisherSource.Subscriber has expressed enough demand.

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

close, executionContext, httpResponseFactory, request

Methods inherited from interface io.servicetalk.concurrent.GracefulAutoCloseable

closeGracefully

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

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

Method Details

connectionContext

HttpConnectionContext connectionContext()

Get the HttpConnectionContext.

Returns:

the HttpConnectionContext.

transportEventIterable

<T> BlockingIterable<? extends T> transportEventIterable(HttpEventKey<T> eventKey)

Returns a BlockingIterable that gives the current value of the setting as well as subsequent changes to the setting 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 setting value.

Parameters:

eventKey - Name of the event to fetch.

Returns:

BlockingIterable for the setting values.

asStreamingConnection

StreamingHttpConnection asStreamingConnection()

Convert this BlockingHttpConnection to the StreamingHttpConnection API.

Note that the resulting StreamingHttpConnection may still be subject to any blocking, in memory aggregation, and other behavior as this BlockingHttpConnection.

Returns:

a StreamingHttpConnection representation of this BlockingHttpConnection.

asConnection

default HttpConnection asConnection()

Convert this BlockingHttpConnection to the HttpConnection API.

Note that the resulting HttpConnection may still be subject to any blocking, in memory aggregation, and other behavior as this BlockingHttpConnection.

Returns:

a HttpConnection representation of this BlockingHttpConnection.

asBlockingStreamingConnection

default BlockingStreamingHttpConnection asBlockingStreamingConnection()

Convert this BlockingHttpConnection to the BlockingStreamingHttpConnection API.

Note that the resulting BlockingStreamingHttpConnection may still be subject to in memory aggregation and other behavior as this BlockingHttpConnection.

Returns:

a BlockingStreamingHttpConnection representation of this BlockingHttpConnection.