Package io.servicetalk.http.api
Interface BlockingStreamingHttpConnection
- All Superinterfaces:
AutoCloseable
,BlockingStreamingHttpRequester
,BlockingStreamingHttpRequestFactory
,GracefulAutoCloseable
- All Known Subinterfaces:
ReservedBlockingStreamingHttpConnection
The equivalent of
StreamingHttpConnection
but with synchronous/blocking APIs instead of asynchronous APIs.-
Method Summary
Modifier and TypeMethodDescriptiondefault BlockingHttpConnection
Convert thisBlockingStreamingHttpConnection
to theBlockingHttpConnection
API.default HttpConnection
Convert thisBlockingStreamingHttpConnection
to theHttpConnection
API.Convert thisBlockingStreamingHttpConnection
to theStreamingHttpConnection
API.Get theHttpConnectionContext
.<T> BlockingIterable<? extends T>
transportEventIterable
(HttpEventKey<T> eventKey) Returns aBlockingIterable
that gives the current value of the setting as well as subsequent changes to the setting value as long as thePublisherSource.Subscriber
has expressed enough demand.Methods inherited from interface io.servicetalk.http.api.BlockingStreamingHttpRequester
close, executionContext, httpResponseFactory, request
Methods inherited from interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory
connect, delete, get, head, newRequest, options, patch, post, put, trace
Methods inherited from interface io.servicetalk.concurrent.GracefulAutoCloseable
closeGracefully
-
Method Details
-
connectionContext
HttpConnectionContext connectionContext()Get theHttpConnectionContext
.- Returns:
- the
HttpConnectionContext
.
-
transportEventIterable
Returns aBlockingIterable
that gives the current value of the setting as well as subsequent changes to the setting value as long as thePublisherSource.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 thisBlockingStreamingHttpConnection
to theStreamingHttpConnection
API.Note that the resulting
StreamingHttpConnection
may still be subject to any blocking, in memory aggregation, and other behavior as thisBlockingStreamingHttpConnection
.- Returns:
- a
StreamingHttpConnection
representation of thisBlockingStreamingHttpConnection
.
-
asConnection
Convert thisBlockingStreamingHttpConnection
to theHttpConnection
API.Note that the resulting
HttpConnection
may still be subject to any blocking, in memory aggregation, and other behavior as thisBlockingStreamingHttpConnection
.- Returns:
- a
HttpConnection
representation of thisBlockingStreamingHttpConnection
.
-
asBlockingConnection
Convert thisBlockingStreamingHttpConnection
to theBlockingHttpConnection
API.Note that the resulting
BlockingHttpConnection
may still be subject to in memory aggregation and other behavior as thisBlockingStreamingHttpConnection
.- Returns:
- a
BlockingHttpConnection
representation of thisBlockingStreamingHttpConnection
.
-