Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W X Z 

A

AbstractCloseableIterable<T> - Class in io.servicetalk.concurrent.internal
An abstract implementation of CloseableIterable that wraps an Iterable.
AbstractCloseableIterable(Iterable<T>) - Constructor for class io.servicetalk.concurrent.internal.AbstractCloseableIterable
New instance.
AbstractCloseableIteratorAsInputStream<T> - Class in io.servicetalk.concurrent.internal
Conversion from a CloseableIterator to a InputStream given a Function to serialize to bytes.
AbstractCloseableIteratorAsInputStream(CloseableIterator<T>) - Constructor for class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
Create a new instance.
AbstractExecutionStrategyResource() - Constructor for class io.servicetalk.http.router.jersey.resources.ExecutionStrategyResources.AbstractExecutionStrategyResource
 
AbstractFilterInterceptorTest - Class in io.servicetalk.http.router.jersey
 
AbstractFilterInterceptorTest(AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest
 
AbstractFilterInterceptorTest.TestGlobalFilter - Class in io.servicetalk.http.router.jersey
 
AbstractFilterInterceptorTest.TestGlobalInterceptor - Class in io.servicetalk.http.router.jersey
 
AbstractFilterInterceptorTest.TestInputConsumingGlobalFilter - Class in io.servicetalk.http.router.jersey
 
AbstractFilterInterceptorTest.UpperCaseInputStream - Class in io.servicetalk.http.router.jersey
 
AbstractHttpRequesterFilterTest - Class in io.servicetalk.http.api
This parameterized test facilitates running HTTP requester filter tests under all calling variations: client, connection, reserved connection, with and without SSL context.
AbstractHttpRequesterFilterTest(AbstractHttpRequesterFilterTest.RequesterType, AbstractHttpRequesterFilterTest.SecurityType) - Constructor for class io.servicetalk.http.api.AbstractHttpRequesterFilterTest
 
AbstractHttpRequesterFilterTest.RequesterType - Enum in io.servicetalk.http.api
 
AbstractHttpRequesterFilterTest.RequestHandler - Interface in io.servicetalk.http.api
Handler for HttpRequester.request(HttpExecutionStrategy, HttpRequest) calls as delegated from the filter under test.
AbstractHttpRequesterFilterTest.RequestWithContextHandler - Interface in io.servicetalk.http.api
Handler for HttpRequester.request(HttpExecutionStrategy, HttpRequest) calls with ConnectionContext information as delegated from the filter under test.
AbstractHttpRequesterFilterTest.SecurityType - Enum in io.servicetalk.http.api
 
AbstractHttpServiceFilterTest - Class in io.servicetalk.http.api
This parameterized test facilitates running HTTP service filter tests under all calling variations: with and without SSL context.
AbstractHttpServiceFilterTest(AbstractHttpServiceFilterTest.SecurityType) - Constructor for class io.servicetalk.http.api.AbstractHttpServiceFilterTest
 
AbstractHttpServiceFilterTest.SecurityType - Enum in io.servicetalk.http.api
 
AbstractJerseyStreamingHttpServiceTest - Class in io.servicetalk.http.router.jersey
 
AbstractJerseyStreamingHttpServiceTest(AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.AbstractJerseyStreamingHttpServiceTest
 
AbstractNonParameterizedJerseyStreamingHttpServiceTest - Class in io.servicetalk.http.router.jersey
 
AbstractNonParameterizedJerseyStreamingHttpServiceTest(AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi - Enum in io.servicetalk.http.router.jersey
 
AbstractResourceTest - Class in io.servicetalk.http.router.jersey
 
AbstractResourceTest(boolean, AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.AbstractResourceTest
 
AbstractResourceTest.TestApplication - Class in io.servicetalk.http.router.jersey
 
AbstractResourceTest.TestFilter - Class in io.servicetalk.http.router.jersey
 
AbstractResourceTest.TestFiltered - Annotation Type in io.servicetalk.http.router.jersey
 
AbstractRetryingFilterBuilder<Builder extends AbstractRetryingFilterBuilder<Builder,Filter,Meta>,Filter,Meta> - Class in io.servicetalk.client.api
An abstract builder for retrying filters.
AbstractRetryingFilterBuilder() - Constructor for class io.servicetalk.client.api.AbstractRetryingFilterBuilder
 
AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<Meta> - Class in io.servicetalk.client.api
A read-only settings for retryable filters.
accept(int, int) - Method in interface io.servicetalk.client.api.internal.ServiceDiscovererUtils.TwoIntsConsumer
Performs this operation on the given arguments.
ACCEPT - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept"
accept(Object, Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
 
accept(Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
accept(State, Payload) - Method in interface io.servicetalk.http.api.TrailersTransformer
Accepts a Payload.
accept(ConnectionContext) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor
Evaluate the passed ConnectionContext to accept or reject.
accept(ConnectionContext) - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
 
ACCEPT_ALL - Static variable in interface io.servicetalk.transport.api.ConnectionAcceptor
ACCEPT all connections.
ACCEPT_CHARSET - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-charset"
ACCEPT_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-encoding"
ACCEPT_LANGUAGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-language"
ACCEPT_PATCH - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-patch"
ACCEPT_RANGES - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-ranges"
accepted() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.ACCEPTED response.
accepted() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.ACCEPTED response.
ACCEPTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
202 Accepted
accepted() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.ACCEPTED response.
ACCESS_CONTROL_ALLOW_CREDENTIALS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-credentials"
ACCESS_CONTROL_ALLOW_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-headers"
ACCESS_CONTROL_ALLOW_METHODS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-methods"
ACCESS_CONTROL_ALLOW_ORIGIN - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-origin"
ACCESS_CONTROL_EXPOSE_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-expose-headers"
ACCESS_CONTROL_MAX_AGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-max-age"
ACCESS_CONTROL_REQUEST_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-request-headers"
ACCESS_CONTROL_REQUEST_METHOD - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-request-method"
accumulate(T) - Method in interface io.servicetalk.concurrent.api.BufferStrategy.Accumulator
Adds the passed item to this BufferStrategy.Accumulator.
accumulated() - Static method in class io.servicetalk.log4j2.mdc.utils.LoggerStringWriter
Get the accumulated content that has been logged.
ackTimeout(Duration) - Method in class io.servicetalk.http.netty.H2KeepAlivePolicies.KeepAlivePolicyBuilder
Set the maximum Duration to wait for an acknowledgment of a previously sent ping.
ackTimeout() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig.KeepAlivePolicy
Duration to wait for acknowledgment from the peer after a ping is sent.
activate(InMemorySpan, boolean) - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
 
activate(Span, boolean) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
activate(InMemorySpan, boolean) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
Same as InMemoryScopeManager.activate(Span, boolean) but the span must be of type InMemorySpan.
active() - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
 
active() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
 
activeCount() - Method in class io.servicetalk.client.servicediscoverer.ServiceDiscovererTestSubscriber
 
activeSpan() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
 
activeSpan() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
 
adaptor() - Method in interface io.servicetalk.http.api.HttpApiConversions.ServiceAdapterHolder
StreamingHttpService that adapts another service to the streaming programming model.
add(PartitionAttributes.Key<T>, T) - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
 
add(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
 
add(PartitionAttributes.Key<T>, T) - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder
Add a key/value pair to this builder.
add(PartitionAttributes) - Method in interface io.servicetalk.client.api.partition.PartitionMap
Add a new PartitionAttributes that is absolutely specified.
add(T) - Method in interface io.servicetalk.concurrent.api.BlockingProcessorSignalsHolder
Adds an item to this holder.
add(T) - Method in interface io.servicetalk.concurrent.api.PublisherProcessorSignalsHolder
Adds an item to this holder.
add(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, Iterable<? extends CharSequence>) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, CharSequence...) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(HttpHeaders) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a new header with the specified name and value.
add(CharSequence, Iterable<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds new headers with the specified name and values.
add(CharSequence, Iterator<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds new headers with the specified name and values.
add(CharSequence, CharSequence...) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds new headers with the specified name and values.
add(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds all header names and values of headers to this object.
addBlockingRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRequestStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingResponseStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRoute(String, Class<?>, String, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBlockingStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBuffer(Buffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Add the given Buffer to this buffer and increment the writerIndex.
addBuffer(Buffer, boolean) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Add the given Buffer to this buffer.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addCookie(HttpCookiePair) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addCookie(HttpCookiePair) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a cookie.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a cookie with the specified name and value.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a cookie.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a cookie with the specified name and value.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequest
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponse
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addHeader(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a new header with the specified name and value.
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addHeaders(HttpHeaders) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds all header names and values of headers object.
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequest
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addIfAbsent(Channel) - Method in class io.servicetalk.transport.netty.internal.ChannelSet
Add a Channel to this ChannelSet, if it is not already present.
addListener(InMemorySpanEventListener) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder
Add a trace event listener.
addOption(Map<ChannelOption, Object>, SocketOption<T>, Object) - Static method in class io.servicetalk.transport.netty.internal.SocketOptionUtils
Convert and add the given SocketOption and value to the ChannelOptions Map.
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequest
 
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Adds a new query parameter with the specified key and value, which will be percent-encoded if needed.
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.HttpRequest
 
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequest
 
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Adds new query parameters with the specified key and values.
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Adds new query parameters with the specified key and values.
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addReference(String, SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
addReference(String, InMemorySpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
addRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addRequestStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
addResponseStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
address() - Method in class io.servicetalk.client.api.DefaultGroupKey
 
address() - Method in class io.servicetalk.client.api.DefaultServiceDiscovererEvent
 
address() - Method in interface io.servicetalk.client.api.GroupKey
Get the address to use when looking for or creating a new client.
address() - Method in interface io.servicetalk.client.api.ServiceDiscovererEvent
Get the resolved address which is the subject of this event.
AddressUtils - Class in io.servicetalk.transport.netty.internal
A utility class to work with addresses.
addRoute(String, Class<?>, String, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.Route to this factory.
addRoute(String, GrpcExecutionStrategy, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.Route to this factory.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addSetCookie(HttpSetCookie) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addSetCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addSetCookie(HttpSetCookie) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a set-cookie.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a set-cookie with the specified name and value.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a set-cookie.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a set-cookie with the specified name and value.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequest
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponse
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addStreamingRoute(String, Class<?>, String, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.StreamingRoute to this factory.
addStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.StreamingRoute to this factory.
addTrailer(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.HttpOutputStream
 
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpPayloadWriter
 
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addTrailers(HttpHeaders) - Method in class io.servicetalk.http.api.HttpOutputStream
 
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpPayloadWriter
 
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequest
 
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponse
 
addWithOverflowProtection(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Adds two positive longs and returns Long.MAX_VALUE if overflow occurs.
addWithOverflowProtection(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Adds two positive ints and returns Integer.MAX_VALUE if overflow occurs.
addWithOverflowProtection(AtomicIntegerFieldUpdater<T>, T, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Increment an integer referred by AtomicIntegerFieldUpdater atomically and saturate to Integer.MAX_VALUE if overflow occurs.
addWithOverflowProtection(AtomicLongFieldUpdater<T>, T, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Increment a long referred by AtomicLongFieldUpdater atomically and saturate to Long.MAX_VALUE if overflow occurs.
addWithOverflowProtectionIfGtEqNegativeOne(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is >=-1 this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithOverflowProtectionIfNotNegative(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is non-negative this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithOverflowProtectionIfNotNegative(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is non-negative this method behaves the same as FlowControlUtils.addWithOverflowProtection(int, int).
addWithOverflowProtectionIfPositive(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is positive this method behaves the same as FlowControlUtils.addWithOverflowProtection(int, int).
addWithOverflowProtectionIfPositive(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is positive this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator
advanceTimeBy(long, TimeUnit) - Method in class io.servicetalk.concurrent.api.TestExecutor
Advance the internal clock time by time in the specified units, executing scheduled tasks whose time has come.
advanceTimeByNoExecuteTasks(long, TimeUnit) - Method in class io.servicetalk.concurrent.api.TestExecutor
Advance the internal clock time by time in the specified units, without executing scheduled tasks.
after() - Method in class io.servicetalk.concurrent.api.ExecutorRule
 
after() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onCancel Runnable argument after Cancellable.cancel() is called for Subscriptions of the returned Completable.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onCancel Runnable argument after Cancellable.cancel() is called for PublisherSource.Subscriptions of the returned Publisher.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onCancel Runnable argument after Cancellable.cancel() is called for Subscriptions of the returned Single.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the whenFinally Runnable argument after any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() CompletableSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
afterFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the corresponding method on afterFinally TerminalSignalConsumer argument after any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() - invokes TerminalSignalConsumer.onComplete() CompletableSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the afterFinally Runnable argument after any of the following terminal methods are called: PublisherSource.Subscriber.onComplete() PublisherSource.Subscriber.onError(Throwable) Cancellable.cancel() for PublisherSource.Subscriptions/PublisherSource.Subscribers of the returned Publisher.
afterFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the whenFinally Runnable argument after any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) SingleSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
afterFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Single
Invokes the corresponding method on afterFinally TerminalSignalConsumer argument after any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) - invokes TerminalSignalConsumer.onComplete() SingleSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
afterFinally(SingleTerminalSignalConsumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
afterFirstWrite(Consumer<FlushStrategy.FlushSender>) - Method in class io.servicetalk.transport.netty.internal.MockFlushStrategy
Invoke some code on the first invocation of WriteEventsListener#itemWritten(Object).
afterOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onComplete Runnable argument after CompletableSource.Subscriber.onComplete() is called for CompletableSource.Subscribers of the returned Completable.
afterOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onComplete Runnable argument after PublisherSource.Subscriber.onComplete() is called for PublisherSource.Subscribers of the returned Publisher.
afterOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onError Consumer argument after CompletableSource.Subscriber.onError(Throwable) is called for CompletableSource.Subscribers of the returned Completable.
afterOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onError Consumer argument after PublisherSource.Subscriber.onError(Throwable) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onError Consumer argument after SingleSource.Subscriber.onError(Throwable) is called for SingleSource.Subscribers of the returned Single.
afterOnNext(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onNext Consumer argument after PublisherSource.Subscriber.onNext(Object) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onSubscribe Consumer argument after CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
afterOnSubscribe(Consumer<? super PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onSubscribe Consumer argument after PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSubscribe Consumer argument after SingleSource.Subscriber.onSubscribe(Cancellable) is called for SingleSource.Subscribers of the returned Single.
afterOnSuccess(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSuccess Consumer argument after SingleSource.Subscriber.onSuccess(Object) is called for SingleSource.Subscribers of the returned Single.
afterRequest(LongConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onRequest LongConsumer argument after PublisherSource.Subscription.request(long) is called for PublisherSource.Subscriptions of the returned Publisher.
afterSubscriber(Supplier<? extends CompletableSource.Subscriber>) - Method in class io.servicetalk.concurrent.api.Completable
Creates a new CompletableSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the CompletableSource.Subscriber methods after the CompletableSource.Subscribers of the returned Completable.
afterSubscriber(Supplier<? extends PublisherSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscriber (via the subscriberSupplier argument) for each new subscribe and invokes all the PublisherSource.Subscriber methods after the PublisherSource.Subscribers of the returned Publisher.
afterSubscriber(Supplier<? extends SingleSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Single
Creates a new SingleSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the SingleSource.Subscriber methods after the SingleSource.Subscribers of the returned Single.
afterSubscription(Supplier<? extends PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscription (via the subscriptionSupplier argument) for each new subscribe and invokes all the PublisherSource.Subscription methods after the PublisherSource.Subscriptions of the returned Publisher.
AGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"age"
allocateMemory(long) - Static method in class io.servicetalk.utils.internal.PlatformDependent
Allocates direct memory.
ALLOW - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"allow"
allowPrematureClosureBeforePayloadBody() - Method in class io.servicetalk.http.netty.H1SpecExceptions
Allows interpreting connection closures as the end of HTTP/1.1 messages if the receiver did not receive any part of the payload body before the connection closure.
allowPrematureClosureBeforePayloadBody() - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder
Allows interpreting connection closures as the end of HTTP/1.1 messages if the receiver did not receive any part of the payload body before the connection closure.
alpnId() - Method in interface io.servicetalk.http.api.HttpProtocolConfig
TLS Application-Layer Protocol Negotiation (ALPN) Protocol ID of the protocol this configuration is for.
alpnId() - Method in interface io.servicetalk.http.netty.H1ProtocolConfig
 
alpnId() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig
 
ALREADY_REPORTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
208 Already Reported
alreadyReported() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
alreadyReported() - Method in interface io.servicetalk.http.api.HttpResponseFactory
alreadyReported() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
amb(Completable...) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
amb(Iterable<Completable>) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
amb(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
amb(Iterable<Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
ambWith(Completable) - Method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of either this Completable or the passed other Completable, whichever terminates first.
ambWith(Single<T>) - Method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of either this Single or the passed other Single, whichever terminates first.
and(Predicate<StreamingHttpRequest>) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches StreamingHttpRequests with a user-specified predicate.
and(BiPredicate<ConnectionContext, StreamingHttpRequest>) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches StreamingHttpRequest and ConnectionContext with a user-specified predicate.
andCookie(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route with a CookieMatcher that matches against HttpSetCookies with the name name.
andHeader(CharSequence) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route with a StringMultiValueMatcher that matches against the value(s) of the name headers.
andIsNotSsl() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests that are not over SSL/TLS.
andIsSsl() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests that are over SSL/TLS.
andMethod(HttpRequestMethod) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the HttpRequestMethod is method.
andMethodIsOneOf(HttpRequestMethod...) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the HttpRequestMethod is one of the methods.
andPathEquals(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path is equal to path.
andPathIsOneOf(String...) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path is equal to any of the specified paths.
andPathMatches(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path matches the regex pathRegex.
andPathMatches(Pattern) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path matches the regex pathRegex.
andPathStartsWith(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path starts with pathPrefix.
andQueryParam(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route with a StringMultiValueMatcher that matches against the value(s) of the request parameter name.
andThen(ChannelInitializer) - Method in interface io.servicetalk.transport.netty.internal.ChannelInitializer
Returns a new ChannelInitializer which will first invoke this initializer and then after.
anyOf(Completable...) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
anyOf(Iterable<Completable>) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
anyOf(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
anyOf(Iterable<Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
api - Variable in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
append(ConnectionFactoryFilter<ResolvedAddress, C>) - Method in interface io.servicetalk.client.api.ConnectionFactoryFilter
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(T) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Appends the passed AsyncCloseable with this CompositeCloseable such that when this CompositeCloseable is closed, all of the previously registered AsyncCloseables are closed too.
append(GrpcServiceFilterFactory<Filter, Service>) - Method in interface io.servicetalk.grpc.api.GrpcServiceFilterFactory
Returns a composed factory that first applies the before factory to its input, and then applies this factory to the result.
append(ConditionalFilterFactory.FilterFactory) - Method in class io.servicetalk.http.api.ConditionalFilterFactory
 
append(MultiAddressHttpClientFilterFactory<U>) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(PartitionHttpClientBuilderConfigurator<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator
append(HttpExecutionStrategyInfluencer) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Append another HttpExecutionStrategyInfluencer to this chain.
append(StreamingHttpClientFilterFactory) - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(StreamingHttpConnectionFilterFactory) - Method in interface io.servicetalk.http.api.StreamingHttpConnectionFilterFactory
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.StreamingHttpServiceFilterFactory
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor
Returns a composed ConnectionAcceptor that first applies this ConnectionAcceptor, and if this is successful then applies after ConnectionAcceptor.
append(ConnectionAcceptorFactory) - Method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
appendAll(AsyncCloseable...) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Appends all the passed AsyncCloseables with this CompositeCloseable such that when this CompositeCloseable is closed, all of these AsyncCloseables are closed too.
appendAll(Iterable<? extends AsyncCloseable>) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Appends all the passed AsyncCloseables with this CompositeCloseable such that when this CompositeCloseable is closed, all of these AsyncCloseables are closed too.
appendClientBuilderFilter(PartitionHttpClientBuilderConfigurator<U, R>) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
Sets a function that allows customizing the SingleAddressHttpClientBuilder used to create the client for a given partition based on its PartitionAttributes.
appendClientFilter(FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientFactory
Appends the passed FilterFactory to this factory.
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
appendClientFilter(MultiAddressHttpClientFilterFactory<U>) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpClient created by this builder for a given UnresolvedAddress.
appendClientFilter(Predicate<StreamingHttpRequest>, MultiAddressHttpClientFilterFactory<U>) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpClient created by this builder for a given UnresolvedAddress, for every request that passes the provided Predicate.
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
appendClientFilterFactory(FilterFactory, FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientFactory
Appends the passed FilterFactory to this client factory.
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Append the filter to the chain of filters used to decorate the ConnectionAcceptor used by this builder.
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in class io.servicetalk.http.api.HttpServerBuilder
Appends the filter to the chain of filters used to decorate the ConnectionAcceptor used by this builder.
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
appendHttpClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Append the filter to the chain of filters used to decorate the client created by this builder.
appendHttpClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Append the filter to the chain of filters used to decorate the client created by this builder, for every request that passes the provided Predicate.
appendHttpServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Append the filter to the chain of filters used to decorate the service used by this builder.
appendHttpServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Append the filter to the chain of filters used to decorate the service used by this builder, for every request that passes the provided Predicate.
appendIfInfluencer(Object) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
If the passed mayBeInfluencer is an HttpExecutionStrategyInfluencer then add it to this chain.
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.HttpRequest
 
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Appends segments to the current HttpRequestMetaData.path(), performing encoding of each segment (including ('/') characters) according to percent-encoding.
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
appendServiceFilter(FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServiceFactory
Appends the passed FilterFactory to this factory.
appendServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.HttpServerBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpService used by this builder.
appendServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.HttpServerBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpService used by this builder, for every request that passes the provided Predicate.
appendServiceFilterFactory(FilterFactory, FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServiceFactory
Appends the passed FilterFactory to this service factory.
application() - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
application() - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest
 
application() - Method in class io.servicetalk.http.router.jersey.ExceptionMapperTest
 
application() - Method in class io.servicetalk.http.router.jersey.ExecutionStrategyTest
 
application() - Method in class io.servicetalk.http.router.jersey.GlobalFiltersTest
 
application() - Method in class io.servicetalk.http.router.jersey.IllBehavedRequestFilterTest
 
application() - Method in class io.servicetalk.http.router.jersey.InputConsumingGlobalFiltersTest
 
application() - Method in class io.servicetalk.http.router.jersey.InterceptorsTest
 
application() - Method in class io.servicetalk.http.router.jersey.MixedModeResourceTest
 
application() - Method in class io.servicetalk.http.router.jersey.SecurityFilterTest
 
APPLICATION_JSON - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/json"
APPLICATION_X_WWW_FORM_URLENCODED - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/x-www-form-urlencoded"
APPLICATION_X_WWW_FORM_URLENCODED_UTF_8 - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/x-www-form-urlencoded; charset=UTF-8"
applicationStatus() - Method in exception io.servicetalk.grpc.api.GrpcStatusException
Returns the status details if any was included or null.
apply(PartitionAttributes, ServiceDiscoverer<U, R, ? extends PartitionedServiceDiscovererEvent<R>>) - Method in interface io.servicetalk.client.api.internal.DefaultPartitionedClientGroup.PartitionedClientFactory
Create a partitioned client.
apply(CompletableSource.Subscriber) - Method in class io.servicetalk.concurrent.api.AutoOnSubscribeCompletableSubscriberFunction
 
apply(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.AutoOnSubscribePublisherSubscriberFunction
 
apply(SingleSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.AutoOnSubscribeSingleSubscriberFunction
 
apply(int, T) - Method in interface io.servicetalk.concurrent.api.BiIntFunction
Evaluates this function on the given arguments.
apply(CompletableSource.Subscriber) - Method in interface io.servicetalk.concurrent.api.CompletableOperator
Implementation of this operator.
apply(CompletableSource.Subscriber) - Method in class io.servicetalk.concurrent.api.ConcurrentCompletableSubscriberFunction
 
apply(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.ConcurrentPublisherSubscriberFunction
 
apply(SingleSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.ConcurrentSingleSubscriberFunction
 
apply(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.DemandCheckingSubscriberFunction
 
apply(Statement, Description) - Method in class io.servicetalk.concurrent.api.LegacyMockedCompletableListenerRule
Deprecated.
 
apply(Statement, Description) - Method in class io.servicetalk.concurrent.api.LegacyMockedSingleListenerRule
Deprecated.
 
apply(CompletableSource.Subscriber) - Method in class io.servicetalk.concurrent.api.NonResubscribeableCompletableSubscriberFunction
 
apply(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.NonResubscribeablePublisherSubscriberFunction
 
apply(SingleSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.NonResubscribeableSingleSubscriberFunction
 
apply(PublisherSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherOperator
Implementation of this operator.
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherToSingleOperator
Implementation of this operator.
apply(CompletableSource.Subscriber) - Method in class io.servicetalk.concurrent.api.SequentialCompletableSubscriberFunction
 
apply(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.SequentialPublisherSubscriberFunction
 
apply(SingleSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.SequentialSingleSubscriberFunction
 
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.SingleOperator
Implementation of this operator.
apply(Statement, Description) - Method in class io.servicetalk.concurrent.internal.ServiceTalkTestTimeout
 
apply(String, String) - Method in interface io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.CredentialsVerifier
Verifies user-id and password, parsed from the 'Basic' HTTP Authentication Scheme credentials.
apply(SingleSource.Subscriber<? super StreamingHttpResponse>) - Method in class io.servicetalk.http.utils.BeforeFinallyHttpOperator
 
apply(FlushStrategy.FlushSender) - Method in class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy
 
apply(FlushStrategy.FlushSender) - Method in interface io.servicetalk.transport.netty.internal.FlushStrategy
Every time a new write that requires custom flushes is initiated, this method is invoked.
apply(FlushStrategy.FlushSender) - Method in class io.servicetalk.transport.netty.internal.MockFlushStrategy
 
apply(FlushStrategy.FlushSender) - Method in class io.servicetalk.transport.netty.internal.SplittingFlushStrategy
 
aroundReadFrom(ReaderInterceptorContext) - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest.TestGlobalInterceptor
 
aroundWriteTo(WriterInterceptorContext) - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest.TestGlobalInterceptor
 
array() - Method in interface io.servicetalk.buffer.api.Buffer
Returns the backing byte array of this buffer.
array() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
arrayOffset() - Method in interface io.servicetalk.buffer.api.Buffer
Returns the offset of the first byte within the backing byte array of this buffer.
arrayOffset() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
ArrayUtils - Class in io.servicetalk.concurrent.internal
Utilities for arrays.
asBlockingClient() - Method in interface io.servicetalk.grpc.api.GrpcClient
Converts this GrpcClient to a blocking client.
asBlockingClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient
asBlockingClient() - Method in interface io.servicetalk.http.api.HttpClient
Convert this HttpClient to the BlockingHttpClient API.
asBlockingClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient
Convert this StreamingHttpClient to the BlockingHttpClient API.
asBlockingConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
asBlockingConnection() - Method in interface io.servicetalk.http.api.HttpConnection
Convert this HttpConnection to the BlockingHttpConnection API.
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
asBlockingRequester(StreamingHttpRequester) - Method in class io.servicetalk.http.api.AbstractHttpRequesterFilterTest
 
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.HttpClient
Convert this HttpClient to the BlockingStreamingHttpClient API.
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.HttpConnection
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
asCharSequence() - Method in class io.servicetalk.http.router.jersey.CharSequenceUtilTest
 
asChildOf(SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
 
asChildOf(Span) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
 
asClient() - Method in interface io.servicetalk.grpc.api.BlockingGrpcClient
Converts this BlockingGrpcClient to a client.
asClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient
Convert this BlockingHttpClient to the HttpClient API.
asClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient
Convert this BlockingStreamingHttpClient to the HttpClient API.
asClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient
Convert this StreamingHttpClient to the HttpClient API.
asClientFilter(U) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory
asConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
Convert this BlockingHttpConnection to the HttpConnection API.
asConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
asConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
 
asConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
 
asConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
 
asConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
Convert this StreamingHttpConnection to the HttpConnection API.
asException() - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns the current status wrapped in a GrpcStatusException.
asException(Supplier<Status>) - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns the current status wrapped in a GrpcStatusException including the supplied details.
asExecutor() - Method in interface io.servicetalk.transport.netty.internal.NettyIoExecutor
Get an Executor which will use an IoExecutor thread for execution.
asInputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer
Return an InputStream that wraps the given Buffer.
asMultiAddressClientFilter() - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory
asOutputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer
Return an OutputStream that wraps the given Buffer.
asReadOnly() - Method in interface io.servicetalk.buffer.api.Buffer
Create a read-only view for this buffer.
asReadOnly() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
asReadOnly(List<String>) - Method in class io.servicetalk.tcp.netty.internal.TcpClientConfig
 
asReadOnly(List<String>) - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig
 
asReadOnly() - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig
Returns this config as a ReadOnlyClientSecurityConfig.
asReadOnly() - Method in class io.servicetalk.transport.netty.internal.ServerSecurityConfig
Returns this config as a ReadOnlyServerSecurityConfig.
assertContainsMdcPair(String, String, String) - Static method in class io.servicetalk.log4j2.mdc.utils.LoggerStringWriter
Verify that an MDC expectedLabel=expectedValue pair is present in value.
asStreamingClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient
Convert this BlockingHttpClient to the StreamingHttpClient API.
asStreamingClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient
asStreamingClient() - Method in interface io.servicetalk.http.api.HttpClient
Convert this HttpClient to the StreamingHttpClient API.
asStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
asStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
asStreamingConnection() - Method in interface io.servicetalk.http.api.HttpConnection
Convert this HttpConnection to the StreamingHttpConnection API.
asStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
 
asStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
 
asStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
 
AsyncCloseable - Interface in io.servicetalk.concurrent.api
Used to close/shutdown a resource.
AsyncCloseables - Class in io.servicetalk.concurrent.api
A utility class to create AsyncCloseables.
AsyncCloseables.CloseableResource - Interface in io.servicetalk.concurrent.api
A resource that can be converted to an AsyncCloseable.
AsyncContext - Class in io.servicetalk.concurrent.api
Presents a static interface to retain state in an asynchronous environment.
AsyncContextInMemoryScopeManager - Class in io.servicetalk.opentracing.asynccontext
A InMemoryScopeManager that uses AsyncContext as the backing storage.
AsyncContextMap - Interface in io.servicetalk.concurrent.api
The key-value map stored in the AsyncContext.
asyncContextMap(AsyncContextMap) - Method in interface io.servicetalk.concurrent.api.AsyncContextMapHolder
asyncContextMap() - Method in interface io.servicetalk.concurrent.api.AsyncContextMapHolder
Get the current AsyncContextMap.
AsyncContextMap.Key<T> - Class in io.servicetalk.concurrent.api
A key identifies a specific object in a AsyncContextMap.
AsyncContextMapHolder - Interface in io.servicetalk.concurrent.api
Interface for setting and getting a AsyncContextMap.
asynchronousResource() - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest
 
AsynchronousResources - Class in io.servicetalk.http.router.jersey.resources
Asynchronous (in JAX-RS lingo) resources.
AsynchronousResources() - Constructor for class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
AsynchronousResourceTest - Class in io.servicetalk.http.router.jersey
 
AsynchronousResourceTest(boolean, AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
AuthenticationException - Exception in io.servicetalk.http.utils.auth
An authentication exception, which indicates that access was denied and usually converts to 401 (Unauthorized) or 407 (Proxy Authentication Required) response.
AuthenticationException(String) - Constructor for exception io.servicetalk.http.utils.auth.AuthenticationException
Creates a new instance.
AUTHORIZATION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"authorization"
AutoClosableUtils - Class in io.servicetalk.concurrent.internal
Utilities for AutoCloseable.
AutoCloseables - Class in io.servicetalk.concurrent.api
A utility class for methods related to AutoCloseable.
autoOnSubscribe() - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Enable calling Subscriber#onSubscribe(Cancellable) automatically upon subscribe.
autoOnSubscribe(AutoOnSubscribeCompletableSubscriberFunction) - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Enable calling Subscriber#onSubscribe(Cancellable) automatically upon subscribe, with the specified AutoOnSubscribeCompletableSubscriberFunction.
autoOnSubscribe() - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Enable calling Subscriber#onSubscribe(Subscription) automatically upon subscribe.
autoOnSubscribe(AutoOnSubscribePublisherSubscriberFunction<T>) - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Enable calling Subscriber#onSubscribe(Subscription) automatically upon subscribe, with the specified AutoOnSubscribePublisherSubscriberFunction.
autoOnSubscribe() - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Enable calling Subscriber#onSubscribe(Cancellable) automatically upon subscribe.
autoOnSubscribe(AutoOnSubscribeSingleSubscriberFunction<T>) - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Enable calling Subscriber#onSubscribe(Cancellable) automatically upon subscribe, with the specified AutoOnSubscribeSingleSubscriberFunction.
AutoOnSubscribeCompletableSubscriberFunction - Class in io.servicetalk.concurrent.api
Calls CompletableSource.Subscriber.onSubscribe(Cancellable) automatically, sending a delegating Cancellable.
AutoOnSubscribeCompletableSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.AutoOnSubscribeCompletableSubscriberFunction
 
AutoOnSubscribePublisherSubscriberFunction<T> - Class in io.servicetalk.concurrent.api
Calls Subscriber#onSubscribe(Subscription) automatically, sending a delegating PublisherSource.Subscription.
AutoOnSubscribePublisherSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.AutoOnSubscribePublisherSubscriberFunction
 
AutoOnSubscribeSingleSubscriberFunction<T> - Class in io.servicetalk.concurrent.api
Calls SingleSource.Subscriber.onSubscribe(Cancellable) automatically, sending a delegating Cancellable.
AutoOnSubscribeSingleSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.AutoOnSubscribeSingleSubscriberFunction
 
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
AutoRetryStrategyProvider - Interface in io.servicetalk.client.api
AutoRetryStrategyProvider.AutoRetryStrategy - Interface in io.servicetalk.client.api
A strategy to use for automatic retries.
available() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
 
await(Publisher<T>, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Publisher by blocking the calling thread.
await(Single<T>, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Single by blocking the calling thread.
await(Completable, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Completable by blocking the calling thread.
awaitCancelled() - Method in class io.servicetalk.concurrent.api.TestCancellable
Wait until TestCancellable.cancel() is called.
awaitCancelledUninterruptibly() - Method in class io.servicetalk.concurrent.api.TestCancellable
Wait until TestCancellable.cancel() is called without being interrupted.
awaitIndefinitely(Publisher<T>) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Publisher by blocking the calling thread.
awaitIndefinitely(Single<T>) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Single by blocking the calling thread.
awaitIndefinitely(Completable) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Completable by blocking the calling thread.
awaitIndefinitelyNonNull(Publisher<T>) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Publisher by blocking the calling thread.
awaitIndefinitelyNonNull(Single<T>) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Single by blocking the calling thread.
awaitIndefinitelyUnchecked(Completable) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Completable by blocking the calling thread.
awaitNonNull(Publisher<T>, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Publisher by blocking the calling thread.
awaitNonNull(Single<T>, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.BlockingTestUtils
Awaits termination of the passed Single by blocking the calling thread.
awaitOnComplete() - Method in class io.servicetalk.concurrent.api.TestCollectingCompletableSubscriber
Block until a terminal signal is received, throws if TestCollectingCompletableSubscriber.onError(Throwable) and returns normally if TestCollectingCompletableSubscriber.onComplete().
awaitOnComplete() - Method in class io.servicetalk.concurrent.api.TestCollectingPublisherSubscriber
Block until a terminal signal is received, throws if TestCollectingPublisherSubscriber.onError(Throwable) and returns normally if TestCollectingPublisherSubscriber.onComplete().
awaitOnComplete(boolean) - Method in class io.servicetalk.concurrent.api.TestCollectingPublisherSubscriber
Block until a terminal signal is received, throws if TestCollectingPublisherSubscriber.onError(Throwable) and returns normally if TestCollectingPublisherSubscriber.onComplete().
awaitOnError() - Method in class io.servicetalk.concurrent.api.TestCollectingCompletableSubscriber
Block until a terminal signal is received, throws if TestCollectingCompletableSubscriber.onComplete() and returns normally if TestCollectingCompletableSubscriber.onError(Throwable).
awaitOnError() - Method in class io.servicetalk.concurrent.api.TestCollectingPublisherSubscriber
Block until a terminal signal is received, throws if TestCollectingPublisherSubscriber.onComplete() and returns normally if TestCollectingPublisherSubscriber.onError(Throwable).
awaitOnError(boolean) - Method in class io.servicetalk.concurrent.api.TestCollectingPublisherSubscriber
Block until a terminal signal is received, throws if TestCollectingPublisherSubscriber.onComplete() and returns normally if TestCollectingPublisherSubscriber.onError(Throwable).
awaitRequestN(long) - Method in class io.servicetalk.concurrent.api.TestSubscription
Wait until the PublisherSource.Subscription.request(long) amount exceeds amount.
awaitRequestNUninterruptibly(long) - Method in class io.servicetalk.concurrent.api.TestSubscription
Wait until the PublisherSource.Subscription.request(long) amount exceeds amount without being interrupted.
awaitResult(Future<T>) - Static method in class io.servicetalk.concurrent.internal.FutureUtils
Await the completion of the passed Future and return its result.
awaitShutdown() - Method in interface io.servicetalk.transport.api.ServerContext
Blocks and awaits shutdown of the server this ServerContext represents.
awaitSubscription() - Method in class io.servicetalk.concurrent.api.TestCollectingCompletableSubscriber
awaitSubscription() - Method in class io.servicetalk.concurrent.api.TestCollectingPublisherSubscriber
Block until #onSubscribe(Subscription).
awaitTermination(Future<Void>) - Static method in class io.servicetalk.concurrent.internal.FutureUtils
Await the completion of the passed Future.

B

backlog(int) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
The maximum queue length for incoming connection indications (a request to connect) is set to the backlog parameter.
backlog(int) - Method in class io.servicetalk.http.api.HttpServerBuilder
Sets the maximum queue length for incoming connection indications (a request to connect) is set to the backlog parameter.
backlog() - Method in class io.servicetalk.tcp.netty.internal.ReadOnlyTcpServerConfig
Returns the maximum queue length for incoming connection indications (a request to connect).
backlog(int) - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig
The maximum queue length for incoming connection indications (a request to connect) is set to the backlog parameter.
BAD_GATEWAY - Static variable in class io.servicetalk.http.api.HttpResponseStatus
502 Bad Gateway
BAD_REQUEST - Static variable in class io.servicetalk.http.api.HttpResponseStatus
400 Bad Request
badGateway() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_GATEWAY response.
badGateway() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.BAD_GATEWAY response.
badGateway() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_GATEWAY response.
badRequest() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_REQUEST response.
badRequest() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.BAD_REQUEST response.
badRequest() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_REQUEST response.
BASE64 - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"base64"
BaseJerseyRouterTestSuite - Class in io.servicetalk.http.router.jersey
 
BaseJerseyRouterTestSuite() - Constructor for class io.servicetalk.http.router.jersey.BaseJerseyRouterTestSuite
 
baseUriFunction(BiFunction<ConnectionContext, HttpRequestMetaData, String>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Set the function used to compute the base URI for the incoming HTTP request.
BasicAuthenticated - Annotation Type in io.servicetalk.http.security.auth.basic.jersey
Indicates that the marked Application, resource class or resource method is authenticated with HTTP Basic and that a SecurityContext needs to be established for the in-flight request.
BasicAuthHttpServiceFilter<UserInfo> - Class in io.servicetalk.http.utils.auth
A StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
BasicAuthHttpServiceFilter.Builder<UserInfo> - Class in io.servicetalk.http.utils.auth
A builder for an StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
BasicAuthHttpServiceFilter.CredentialsVerifier<UserInfo> - Interface in io.servicetalk.http.utils.auth
Verifies user-id and password, parsed from the 'Basic' HTTP Authentication Scheme credentials.
BasicAuthPrincipal<UserInfo> - Class in io.servicetalk.http.security.auth.basic.jersey
A generic Principal that wraps a user provided UserInfo.
BasicAuthPrincipal(UserInfo) - Constructor for class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
Create a new instance.
BasicAuthSecurityContext - Class in io.servicetalk.http.security.auth.basic.jersey
A generic SecurityContext that wraps a user provided Principal, and which is designed for the SecurityContext.BASIC_AUTH authentication scheme.
BasicAuthSecurityContext(Principal, boolean) - Constructor for class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
Creates a new instance, which has no support for roles.
BasicAuthSecurityContext(Principal, boolean, Predicate<String>) - Constructor for class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
Creates a new instance.
BasicAuthSecurityContextFilters - Class in io.servicetalk.http.security.auth.basic.jersey
Factory methods for building ContainerRequestFilter that establish SecurityContexts for requests authenticated with the Basic HTTP Authentication Scheme (RFC7617).
BasicAuthSecurityContextFilters.AbstractBuilder<B extends BasicAuthSecurityContextFilters.AbstractBuilder,PF,SCF> - Class in io.servicetalk.http.security.auth.basic.jersey
A builder for ContainerRequestFilter instances.
BasicAuthSecurityContextFilters.NoUserInfoBuilder - Class in io.servicetalk.http.security.auth.basic.jersey
A builder that can be used when no user info is stored in AsyncContext.
BasicAuthSecurityContextFilters.UserInfoBuilder<UserInfo> - Class in io.servicetalk.http.security.auth.basic.jersey
A builder that can be used when user info is stored in AsyncContext.
batchFlush(int, Publisher<?>) - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
Creates a FlushStrategy that will flush writes in a batch of batchSize or on expiration of a batch duration i.e.
batchSpans(int, Duration) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Configure batching of spans before sending it to the zipkin collector.
before() - Method in class io.servicetalk.concurrent.api.ExecutorRule
 
before() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
beforeCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onCancel Runnable argument before Cancellable.cancel() is called for Subscriptions of the returned Completable.
beforeCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onCancel Runnable argument before Cancellable.cancel() is called for PublisherSource.Subscriptions of the returned Publisher.
beforeCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onCancel Runnable argument before Cancellable.cancel() is called for Subscriptions of the returned Single.
beforeFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the whenFinally Runnable argument before any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() CompletableSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
beforeFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the corresponding method on beforeFinally TerminalSignalConsumer argument before any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() - invokes TerminalSignalConsumer.onComplete() CompletableSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
beforeFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the beforeFinally Runnable argument before any of the following terminal methods are called: PublisherSource.Subscriber.onComplete() PublisherSource.Subscriber.onError(Throwable) Cancellable.cancel() for PublisherSource.Subscriptions/PublisherSource.Subscribers of the returned Publisher.
beforeFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
beforeFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the whenFinally Runnable argument before any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) SingleSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
beforeFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Single
Invokes the corresponding method on beforeFinally TerminalSignalConsumer argument before any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) - invokes TerminalSignalConsumer.onComplete() SingleSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
beforeFinally(SingleTerminalSignalConsumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
BeforeFinallyHttpOperator - Class in io.servicetalk.http.utils
Helper operator for signaling the end of an HTTP Request/Response cycle.
BeforeFinallyHttpOperator(TerminalSignalConsumer) - Constructor for class io.servicetalk.http.utils.BeforeFinallyHttpOperator
Create a new instance.
BeforeFinallyHttpOperator(Runnable) - Constructor for class io.servicetalk.http.utils.BeforeFinallyHttpOperator
Create a new instance.
beforeOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onComplete Runnable argument before CompletableSource.Subscriber.onComplete() is called for CompletableSource.Subscribers of the returned Completable.
beforeOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onComplete Runnable argument before PublisherSource.Subscriber.onComplete() is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onError Consumer argument before CompletableSource.Subscriber.onError(Throwable) is called for CompletableSource.Subscribers of the returned Completable.
beforeOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onError Consumer argument before PublisherSource.Subscriber.onError(Throwable) is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onError Consumer argument before SingleSource.Subscriber.onError(Throwable) is called for SingleSource.Subscribers of the returned Single.
beforeOnNext(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onNext Consumer argument before PublisherSource.Subscriber.onNext(Object) is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onSubscribe Consumer argument before CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
beforeOnSubscribe(Consumer<? super PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onSubscribe Consumer argument before PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSubscribe Consumer argument before SingleSource.Subscriber.onSubscribe(Cancellable) is called for SingleSource.Subscribers of the returned Single.
beforeOnSuccess(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSuccess Consumer argument before SingleSource.Subscriber.onSuccess(Object) is called for SingleSource.Subscribers of the returned Single.
beforeRequest(LongConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onRequest LongConsumer argument before PublisherSource.Subscription.request(long) is called for PublisherSource.Subscriptions of the returned Publisher.
beforeSubscriber(Supplier<? extends CompletableSource.Subscriber>) - Method in class io.servicetalk.concurrent.api.Completable
Creates a new CompletableSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the CompletableSource.Subscriber methods before the CompletableSource.Subscribers of the returned Completable.
beforeSubscriber(Supplier<? extends PublisherSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the PublisherSource.Subscriber methods before the PublisherSource.Subscribers of the returned Publisher.
beforeSubscriber(Supplier<? extends SingleSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Single
Creates a new SingleSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the SingleSource.Subscriber methods before the SingleSource.Subscribers of the returned Single.
beforeSubscription(Supplier<? extends PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscription (via the subscriptionSupplier argument) on each call to subscribe and invokes all the PublisherSource.Subscription methods before the PublisherSource.Subscriptions of the returned Publisher.
BiIntFunction<T,R> - Interface in io.servicetalk.concurrent.api
A special function that takes an int and a custom argument and returns the result.
BiIntPredicate<T> - Interface in io.servicetalk.concurrent.api
A special predicate that takes an int and a custom argument to evaluate.
BINARY - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"binary"
bind(GrpcServiceFactory.ServerBinder, ExecutionContext) - Method in class io.servicetalk.grpc.api.GrpcServiceFactory
Use the passed GrpcServiceFactory.ServerBinder to bind an appropriate gRPC service for the server.
bind(HttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds an HttpService to the associated server.
bind(ExecutionContext, int, ConnectionAcceptor, Function<NettyConnection<Buffer, Buffer>, Completable>, ExecutionStrategy) - Method in class io.servicetalk.tcp.netty.internal.TcpServer
Starts the server at the passed port and invoke the passed service for each accepted connection.
bind(SocketAddress, ReadOnlyTcpServerConfig, boolean, ExecutionContext, ConnectionAcceptor, Function<Channel, Single<T>>, Consumer<T>) - Static method in class io.servicetalk.tcp.netty.internal.TcpServerBinder
Create a ServerContext that represents a socket which is bound and listening on the listenAddress.
bindBlocking(BlockingHttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds a BlockingHttpService to the associated server.
bindBlockingStreaming(BlockingStreamingHttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds a BlockingStreamingHttpService to the associated server.
bindStreaming(StreamingHttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds a StreamingHttpService to the associated server.
BlockingGrpcClient<Client extends GrpcClient> - Interface in io.servicetalk.grpc.api
A blocking client to a gRPC service.
BlockingGrpcService - Interface in io.servicetalk.grpc.api
A blocking gRPC service.
BlockingHttpClient - Interface in io.servicetalk.http.api
The equivalent of HttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpConnection - Interface in io.servicetalk.http.api
The equivalent of HttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpRequester - Interface in io.servicetalk.http.api
The equivalent of HttpRequester with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpService - Interface in io.servicetalk.http.api
The equivalent of HttpService but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingIterable<T> - Interface in io.servicetalk.concurrent
An Iterable which supports generation of BlockingIterators.
BlockingIterable.Processor<T> - Interface in io.servicetalk.concurrent
A BlockingIterable that supports to dynamically emitting items using BlockingIterable.Processor.next(Object).
BlockingIterables - Class in io.servicetalk.concurrent.internal
Utility methods for BlockingIterable.
BlockingIterator<T> - Interface in io.servicetalk.concurrent
An Iterator that is also an AutoCloseable and whose blocking operations support timeout durations.
BlockingProcessorSignalsHolder<T> - Interface in io.servicetalk.concurrent.api
A holder of items for a BlockingIterable.Processor.
BlockingSpliterator<T> - Interface in io.servicetalk.concurrent
An Spliterator which supports AutoCloseable.close().
BlockingStreamingHttpClient - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpConnection - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpRequest - Interface in io.servicetalk.http.api
The equivalent of HttpRequest but provides the payload as a BlockingIterable.
BlockingStreamingHttpRequester - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpRequester but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpRequestFactory - Interface in io.servicetalk.http.api
A factory for creating BlockingStreamingHttpRequests.
BlockingStreamingHttpRequestResponseFactory - Interface in io.servicetalk.http.api
BlockingStreamingHttpResponse - Interface in io.servicetalk.http.api
The equivalent of HttpResponse but provides the payload as a BlockingIterable.
BlockingStreamingHttpResponseFactory - Interface in io.servicetalk.http.api
A factory for creating BlockingStreamingHttpResponses.
BlockingStreamingHttpServerResponse - Class in io.servicetalk.http.api
The equivalent of HttpResponse but provides an ability to write the payload to an HttpPayloadWriter.
BlockingStreamingHttpService - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpService but with synchronous/blocking APIs instead of asynchronous APIs.
blockingStreamingResponseFactory() - Method in class io.servicetalk.http.api.HttpServiceContext
blockingStreamingResponseFactory() - Method in class io.servicetalk.http.api.TestHttpServiceContext
 
BlockingTestUtils - Class in io.servicetalk.concurrent.api
Utilities to await results of an asynchronous computation either by blocking the calling thread.
bogusChunked() - Method in class io.servicetalk.http.router.jersey.resources.SynchronousResources
 
bogusChunked() - Method in class io.servicetalk.http.router.jersey.SynchronousResourceTest
 
boundaries() - Method in interface io.servicetalk.concurrent.api.BufferStrategy
Returns a Publisher representing asynchronous buffer boundaries.
BOUNDARY - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"boundary"
Buffer - Interface in io.servicetalk.buffer.api
An arbitrary and sequential accessible sequence of zero or more bytes (octets).
buffer(BufferStrategy<T, BC, B>) - Method in class io.servicetalk.concurrent.api.Publisher
Create a Publisher that buffers items from this Publisher and emit those buffers instead of the individual items.
BufferAllocator - Interface in io.servicetalk.buffer.api
An API to allocate Buffers.
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Sets the BufferAllocator to be used by this server.
bufferAllocator() - Method in class io.servicetalk.http.api.DefaultHttpExecutionContext
 
bufferAllocator() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
 
bufferAllocator() - Method in class io.servicetalk.http.api.ExecutionContextToHttpExecutionContext
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.HttpServerBuilder
Sets the BufferAllocator to be used by this server.
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
bufferAllocator() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
 
bufferAllocator() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
 
bufferAllocator() - Method in interface io.servicetalk.transport.api.ExecutionContext
Return the BufferAllocator that can be used to allocate Buffers if needed.
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Sets the BufferAllocator to use.
bufferAllocator() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
BufferAllocators - Class in io.servicetalk.buffer.netty
Available BufferAllocators.
BufferHandler - Class in io.servicetalk.transport.netty.internal
A ChannelHandler that converts does the following conversions: Buffer to ByteBuf for writes. BufferHolder to ByteBuf for writes. ByteBuf to Buffer for reads. ByteBufHolder to Buffer for reads. This also releases any ByteBuf once converted to Buffer.
BufferHolder - Interface in io.servicetalk.buffer.api
An object which contains a Buffer.
BufferPublisherInputStream - Class in io.servicetalk.http.router.jersey.internal
An InputStream built around a Publisher<Buffer>, which can either be read OIO style or provide its wrapped Publisher.
BufferPublisherInputStream(Publisher<Buffer>, int) - Constructor for class io.servicetalk.http.router.jersey.internal.BufferPublisherInputStream
Creates a new BufferPublisherInputStream instance.
bufferResources() - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest
 
bufferResponse() - Method in class io.servicetalk.http.router.jersey.ExceptionMapperTest
 
bufferSizeHint() - Method in interface io.servicetalk.concurrent.api.BufferStrategy
A rough estimate of the number of items in a buffer.
BufferStrategies - Class in io.servicetalk.concurrent.api
A static factory of BufferStrategy instances.
BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B> - Interface in io.servicetalk.concurrent.api
A strategy for buffering items emitted from a Publisher.
BufferStrategy.Accumulator<T,B> - Interface in io.servicetalk.concurrent.api
An intermediate mutable object that holds items till it is finished.
BufferUtils - Class in io.servicetalk.buffer.netty
Internal utilities for Buffers.
build(AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<Meta>) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Builds a retrying Filter for provided ReadOnlyRetryableSettings<Meta>.
build() - Method in class io.servicetalk.client.api.DefaultAutoRetryStrategyProvider.Builder
build() - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
 
build() - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder
build(Function<CompletableSource.Subscriber, CompletableSource.Subscriber>) - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Create a TestCompletable using the specified subscriber function.
build() - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Create a TestCompletable as configured by the builder.
build() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber.Builder
Create a TestCompletableSubscriber as configured by the builder.
build(Function<PublisherSource.Subscriber<? super T>, PublisherSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Create a TestPublisher using the specified subscriber function.
build() - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Create a TestPublisher as configured by the builder.
build() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
Create a TestPublisherSubscriber as configured by the builder.
build(Function<SingleSource.Subscriber<? super T>, SingleSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Create a TestSingle using the specified subscriber function.
build() - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Create a TestSingle as configured by the builder.
build() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber.Builder
Create a TestSingleSubscriber as configured by the builder.
build(GrpcClientFactory<Client, ?, Filter, FilterableClient, FilterFactory>) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Builds a gRPC client.
build(GrpcClientFactory<Client, ?, Filter, FilterableClient, FilterFactory>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.MultiClientBuilder
Builds a gRPC client.
build() - Method in class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder
Builds a new GrpcExecutionStrategy.
build() - Method in class io.servicetalk.grpc.protobuf.ProtoBufSerializationProviderBuilder
Builds a new GrpcSerializationProvider containing all the message types registered with this builder.
build() - Method in class io.servicetalk.http.api.HttpExecutionStrategies.Builder
Builds a new HttpExecutionStrategy.
build(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Builds this chain and returns the head HttpExecutionStrategyInfluencer for the chain.
build() - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Builds this chain and returns the head HttpExecutionStrategyInfluencer for the chain.
build() - Method in class io.servicetalk.http.netty.DefaultHttpLoadBalancerFactory.Builder
Builds a DefaultHttpLoadBalancerFactory using the properties configured on this builder.
build() - Method in class io.servicetalk.http.netty.H1ProtocolConfigBuilder
build() - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder
build() - Method in class io.servicetalk.http.netty.H2KeepAlivePolicies.KeepAlivePolicyBuilder
build() - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder
build(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the HttpService for the specified JAX-RS Application.
build(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the HttpService for the specified JAX-RS Application class.
build() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters.AbstractBuilder
Build a new ContainerRequestFilter instance.
build(AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<HttpRequestMetaData>) - Method in class io.servicetalk.http.utils.RetryingHttpRequesterFilter.Builder
 
build() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Builds a new HttpReporter instance with this builder's options.
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.LoggingReporter.Builder
Builds a new LoggingReporter instance with this builder's options.
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Builds a new UdpReporter instance with this builder's options.
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher.Builder
Builds the ZipkinPublisher with supplied options.
build() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Builds a new ExecutionContext or return GlobalExecutionContext.globalExecutionContext() if none of the components are set in this builder.
buildARecordDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Build a new ServiceDiscoverer which targets host addresses (e.g.
buildBlocking(GrpcClientFactory<?, BlockingClient, Filter, FilterableClient, FilterFactory>) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Builds a blocking gRPC client.
buildBlocking(GrpcClientFactory<?, BlockingClient, Filter, FilterableClient, FilterFactory>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.MultiClientBuilder
Builds a blocking gRPC client.
buildBlocking(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingHttpService for the specified JAX-RS Application.
buildBlocking(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingHttpService for the specified JAX-RS Application class.
buildBlockingStreaming(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingStreamingHttpService for the specified JAX-RS Application.
buildBlockingStreaming(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingStreamingHttpService for the specified JAX-RS Application class.
Builder() - Constructor for class io.servicetalk.client.api.DefaultAutoRetryStrategyProvider.Builder
 
Builder() - Constructor for class io.servicetalk.concurrent.api.TestCompletable.Builder
 
Builder() - Constructor for class io.servicetalk.concurrent.api.TestCompletableSubscriber.Builder
 
Builder() - Constructor for class io.servicetalk.concurrent.api.TestPublisher.Builder
 
Builder() - Constructor for class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
 
Builder() - Constructor for class io.servicetalk.concurrent.api.TestSingle.Builder
 
Builder() - Constructor for class io.servicetalk.concurrent.api.TestSingleSubscriber.Builder
 
Builder() - Constructor for class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder
 
Builder() - Constructor for class io.servicetalk.http.netty.H1SpecExceptions.Builder
 
Builder(BasicAuthHttpServiceFilter.CredentialsVerifier<UserInfo>, String) - Constructor for class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder
Creates a new builder for an StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
Builder() - Constructor for class io.servicetalk.http.utils.RetryingHttpRequesterFilter.Builder
 
Builder(InMemoryScopeManager) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder
Constructs a builder for an DefaultInMemoryTracer.
Builder(SingleAddressHttpClientBuilder<?, ?>) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Builder(String) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.reporter.LoggingReporter.Builder
Creates a new instance.
Builder(SocketAddress) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Create a new UdpReporter.Builder for a given collectorAddress.
Builder(String, Reporter<Span>) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher.Builder
Create a new instance.
BuilderUtils - Class in io.servicetalk.transport.netty.internal
Utilities which are used for builders.
buildMulti() - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Returns a GrpcClientBuilder.MultiClientBuilder to be used to create multiple clients sharing the same underlying transport instance.
buildProxy() - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder
Creates a new instance for proxy service.
buildRouter(HttpServerBuilder, HttpService) - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
buildRouter(HttpServerBuilder, StreamingHttpService) - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
buildRouter(HttpServerBuilder, BlockingHttpService) - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
buildRouter(HttpServerBuilder, BlockingStreamingHttpService) - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
buildRouter(HttpServerBuilder, HttpService) - Method in class io.servicetalk.http.router.jersey.MixedModeResourceTest
 
buildRouter(HttpServerBuilder, StreamingHttpService) - Method in class io.servicetalk.http.router.jersey.MixedModeResourceTest
 
buildRouter(HttpServerBuilder, BlockingHttpService) - Method in class io.servicetalk.http.router.jersey.MixedModeResourceTest
 
buildRouter(HttpServerBuilder, BlockingStreamingHttpService) - Method in class io.servicetalk.http.router.jersey.MixedModeResourceTest
 
buildServer() - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder
Creates a new instance for non-proxy service.
buildSpan(String) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
 
buildSpan(String) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
 
buildSrvDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Build a new ServiceDiscoverer which queries SRV Resource Records corresponding to serviceName.
buildStreaming(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the StreamingHttpService for the specified JAX-RS Application.
buildStreaming(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the StreamingHttpService for the specified JAX-RS Application class.
buildStreaming() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteStarter
Builds the StreamingHttpService that performs the configured routing.
buildStreaming() - Method in class io.servicetalk.http.router.predicate.HttpPredicateRouterBuilder
 
buildWithConstantBackoff(Duration) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds the passed constant Duration as a delay between retries.
buildWithConstantBackoff(Duration, Executor) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds the passed constant Duration as a delay between retries.
buildWithConstantBackoffAndJitter(Duration) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds a randomized delay between retries and uses the passed Duration as a maximum delay possible.
buildWithConstantBackoffAndJitter(Duration, Executor) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds a randomized delay between retries and uses the passed Duration as a maximum delay possible.
buildWithExponentialBackoff(Duration) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds a delay between retries.
buildWithExponentialBackoff(Duration, Executor) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds a delay between retries.
buildWithExponentialBackoffAndJitter(Duration) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds a delay between retries.
buildWithExponentialBackoffAndJitter(Duration, Executor) - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which adds a delay between retries.
buildWithImmediateRetries() - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
Creates a new retrying Filter which retries without delay.
ByteProcessor - Interface in io.servicetalk.buffer.api
Provides a mechanism to iterate over a collection of bytes.
BYTES - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"bytes"
bytesBefore(byte) - Method in interface io.servicetalk.buffer.api.Buffer
Locates the first occurrence of the specified value in this buffer.
bytesBefore(int, byte) - Method in interface io.servicetalk.buffer.api.Buffer
Locates the first occurrence of the specified value in this buffer.
bytesBefore(int, int, byte) - Method in interface io.servicetalk.buffer.api.Buffer
Locates the first occurrence of the specified value in this buffer.
bytesBefore(byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
bytesBefore(int, byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
bytesBefore(int, int, byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
ByteToMessageDecoder - Class in io.servicetalk.transport.netty.internal
ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an other Message type.
ByteToMessageDecoder(ByteBufAllocator) - Constructor for class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Create a new instance.

C

CACHE_CONTROL - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"cache-control"
CACHEABLE - Static variable in class io.servicetalk.http.api.HttpRequestMethod.Properties
As defined in Method Definitions, methods which are cacheable, but not safe or idempotent.
cached() - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
cached(ThreadFactory) - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
calculateDifference(List<? extends T>, List<? extends T>, Comparator<T>, ServiceDiscovererUtils.TwoIntsConsumer) - Static method in class io.servicetalk.client.api.internal.ServiceDiscovererUtils
Given a sorted list of currently active addresses, and a new set of unsorted active address calculate the ServiceDiscovererEvents.
calculateMaxQueueSize(int) - Method in interface io.servicetalk.concurrent.api.GroupedPublisher.QueueSizeProvider
Calculate the maximum queue size for a particular GroupedPublisher key.
calculateSourceRequested(AtomicLongFieldUpdater<T>, AtomicLongFieldUpdater<T>, AtomicLongFieldUpdater<T>, int, T) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Attempts to increment sourceRequestedUpdater in order to make it the same as requestNUpdater while not exceeding the limit.
cancel() - Method in class io.servicetalk.concurrent.api.DeferredEmptySubscription
 
cancel() - Method in class io.servicetalk.concurrent.api.LegacyMockedCompletableListenerRule
Deprecated.
 
cancel() - Method in class io.servicetalk.concurrent.api.LegacyMockedSingleListenerRule
Deprecated.
 
cancel() - Method in interface io.servicetalk.concurrent.api.SingleTerminalSignalConsumer
Callback to indicate termination via Cancellable.cancel().
cancel() - Method in interface io.servicetalk.concurrent.api.TerminalSignalConsumer
Callback to indicate termination via Cancellable.cancel().
cancel() - Method in class io.servicetalk.concurrent.api.TestCancellable
 
cancel() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber
cancel() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber
Cancels the PublisherSource.Subscription received by #onSubscribe(Subscription).
cancel() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber
cancel() - Method in interface io.servicetalk.concurrent.Cancellable
Sends a hint to the producer of the associated asynchronous execution that the consumer related to this Cancellable is not interested in the outcome of the execution.
cancel() - Method in class io.servicetalk.concurrent.internal.ConcurrentSubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.DelayedCancellable
 
cancel() - Method in class io.servicetalk.concurrent.internal.DelayedSubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.EmptySubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.ScalarValueSubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.SequentialCancellable
 
cancel() - Method in class io.servicetalk.concurrent.internal.ThreadInterruptingCancellable
 
cancellable() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber
Returns the Cancellable received by TestCompletableSubscriber.onSubscribe(Cancellable), or null if no Cancellable has been received.
cancellable() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber
Returns the Cancellable received by TestSingleSubscriber.onSubscribe(Cancellable), or null if no Cancellable has been received.
Cancellable - Interface in io.servicetalk.concurrent
An entity that can be cancelled.
cancellableReceived() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber
Returns true if TestCompletableSubscriber.onSubscribe(Cancellable) has been called, false otherwise.
cancellableReceived() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber
Returns true if TestSingleSubscriber.onSubscribe(Cancellable) has been called, false otherwise.
CancellableResources - Class in io.servicetalk.http.router.jersey.resources
 
CancellableResources() - Constructor for class io.servicetalk.http.router.jersey.resources.CancellableResources
 
CancellationTest - Class in io.servicetalk.http.router.jersey
 
CancellationTest() - Constructor for class io.servicetalk.http.router.jersey.CancellationTest
 
cancelledDelayedText() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
cancelOffload() - Method in class io.servicetalk.http.router.jersey.CancellationTest
 
cancelOioStreams() - Method in class io.servicetalk.http.router.jersey.CancellationTest
 
cancelRsStreams() - Method in class io.servicetalk.http.router.jersey.CancellationTest
 
cancelSingle() - Method in class io.servicetalk.http.router.jersey.CancellationTest
 
cancelSse() - Method in class io.servicetalk.http.router.jersey.CancellationTest
 
cancelSuspended() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
cancelSuspended() - Method in class io.servicetalk.http.router.jersey.CancellationTest
 
capacity() - Method in interface io.servicetalk.buffer.api.Buffer
Returns the number of bytes (octets) this buffer can contain.
capacity(int) - Method in interface io.servicetalk.buffer.api.Buffer
Sets the capacity of this buffer.
capacity(int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
capacity() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
capacity(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
catchPayloadFailure(Object, Throwable, HttpHeaders) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
 
catchPayloadFailure(State, Throwable, HttpHeaders) - Method in interface io.servicetalk.http.api.TrailersTransformer
Invoked once all Payload instances are accepted and the payload stream has terminated with an error.
catchUnexpected(Throwable, Throwable) - Static method in class io.servicetalk.concurrent.internal.ThrowableUtils
Used in scenarios where multiple operations which aren't expected to throw but exception propagation must be delayed to preserve control flow.
cause() - Method in class io.servicetalk.concurrent.internal.TerminalNotification
Returns the cause of error if this is an error notification.
cause() - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns the cause, can be null.
cf() - Method in class io.servicetalk.http.router.jersey.resources.ExecutionStrategyResources.ResourceUnsupportedAsync
 
channel() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
Get access to the underlying Channel.
CHANNEL_CLOSEABLE_KEY - Static variable in class io.servicetalk.transport.netty.internal.ChannelSet
 
channelInactive(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
 
ChannelInitializer - Interface in io.servicetalk.transport.netty.internal
Configures a Channel.
channelRead(ChannelHandlerContext, Object) - Method in class io.servicetalk.transport.netty.internal.BufferHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
 
channelReadComplete(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
 
ChannelSet - Class in io.servicetalk.transport.netty.internal
Manages a set of Channels to provide a mechanism for closing all of them.
ChannelSet(Executor) - Constructor for class io.servicetalk.transport.netty.internal.ChannelSet
New instance.
CharSequences - Class in io.servicetalk.http.api
Provides factory methods for creating CharSequence implementations.
CharSequenceUtilTest - Class in io.servicetalk.http.router.jersey
 
CharSequenceUtilTest() - Constructor for class io.servicetalk.http.router.jersey.CharSequenceUtilTest
 
CHARSET - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"charset"
check() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
check() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
checkDuplicateSubscription(PublisherSource.Subscription, PublisherSource.Subscription) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Checks for an already existing PublisherSource.Subscription and if one is given calls Cancellable.cancel() on next and returns false.
CHUNKED - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"chunked"
CI - Static variable in class io.servicetalk.concurrent.internal.ServiceTalkTestTimeout
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.grpc.api.GrpcServerSecurityConfigurator
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.http.api.HttpServerSecurityConfigurator
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator
 
ciphers(Iterable<String>) - Method in interface io.servicetalk.transport.api.SecurityConfigurator
The cipher suites to enable, in the order of preference.
ciphers(Iterable<String>) - Method in interface io.servicetalk.transport.api.ServerSecurityConfigurator
 
ciphers(Iterable<String>) - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig
The cipher suites to enable, in the order of preference.
ciphers(Iterable<String>) - Method in class io.servicetalk.transport.netty.internal.ServerSecurityConfig
The cipher suites to enable, in the order of preference.
clear() - Method in interface io.servicetalk.buffer.api.Buffer
Sets the readerIndex and writerIndex of this buffer to 0.
clear() - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
clear() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
clear() - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to clear all the key/value pairs from the current context.
clear() - Method in interface io.servicetalk.concurrent.api.AsyncContextMap
Clear the contents of this AsyncContextMap.
clear() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
clear() - Method in interface io.servicetalk.http.api.HttpHeaders
Removes all headers.
clear() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
clientAuth(ServerSecurityConfigurator.ClientAuth) - Method in interface io.servicetalk.grpc.api.GrpcServerSecurityConfigurator
 
clientAuth(ServerSecurityConfigurator.ClientAuth) - Method in interface io.servicetalk.http.api.HttpServerSecurityConfigurator
 
clientAuth(ServerSecurityConfigurator.ClientAuth) - Method in interface io.servicetalk.transport.api.ServerSecurityConfigurator
Sets the client authentication mode.
clientAuth - Variable in class io.servicetalk.transport.netty.internal.ReadOnlyServerSecurityConfig
 
clientAuth() - Method in class io.servicetalk.transport.netty.internal.ReadOnlyServerSecurityConfig
clientAuth(ServerSecurityConfigurator.ClientAuth) - Method in class io.servicetalk.transport.netty.internal.ServerSecurityConfig
Sets the client authentication mode.
ClientGroup<Key,Client extends ListenableAsyncCloseable> - Interface in io.servicetalk.client.api
A data-structure capable of holding arbitrary number of clients and bridging lifecycle events across all clients managed by the group.
ClientInvoker<State> - Interface in io.servicetalk.http.api
A function that given flattened stream of HttpRequestMetaData, payload and trailers, for the passed StreamingHttpRequest returns a Single.
ClientSecurityConfig - Class in io.servicetalk.transport.netty.internal
Client security configuration.
ClientSecurityConfig(String, int) - Constructor for class io.servicetalk.transport.netty.internal.ClientSecurityConfig
Creates new instance.
ClientSecurityConfigurator - Interface in io.servicetalk.transport.api
A SecurityConfigurator contract for clients.
close() - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Closes all contained AsyncCloseables and awaits termination of all of them.
close() - Method in class io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream
 
close() - Method in class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
 
close() - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
 
close() - Method in interface io.servicetalk.concurrent.BlockingIterable.Processor
Closes this BlockingIterable and all the current or future BlockingIterators.
close() - Method in interface io.servicetalk.concurrent.BlockingIterator
This method is used to communicate that you are no longer interested in consuming data.
close() - Method in interface io.servicetalk.concurrent.BlockingSpliterator
This method is used to communicate that you are no longer interested in consuming data.
close() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
 
close() - Method in interface io.servicetalk.grpc.api.BlockingGrpcService
 
close() - Method in interface io.servicetalk.grpc.api.GrpcClient
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingRequestStreamingRoute
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingResponseStreamingRoute
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingRoute
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingStreamingRoute
 
close() - Method in interface io.servicetalk.http.api.BlockingHttpRequester
 
close() - Method in interface io.servicetalk.http.api.BlockingHttpService
 
close() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequester
 
close() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpService
 
close() - Method in interface io.servicetalk.http.api.HttpClient
 
close() - Method in interface io.servicetalk.http.api.HttpConnection
 
CLOSE - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"close"
close() - Method in interface io.servicetalk.http.api.StreamingHttpClient
 
close() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
 
close() - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest.UpperCaseInputStream
 
close() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
close() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
close() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher
Blocking close method delegates to ZipkinPublisher.closeAsync().
close() - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
Disposes this StreamingDeserializer.
close() - Method in interface io.servicetalk.transport.api.ServerContext
 
CloseableIterable<T> - Interface in io.servicetalk.concurrent
An Iterable which supports generation of CloseableIterators.
CloseableIterator<T> - Interface in io.servicetalk.concurrent
An Iterator that is also an AutoCloseable.
CloseableIteratorBufferAsInputStream - Class in io.servicetalk.concurrent.api.internal
Conversion from a CloseableIterator of Buffers to a InputStream.
CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer>) - Constructor for class io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream
Create a new instance.
closeAndReThrowIoException(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils
Call AutoCloseable.close() and re-throw any exceptions as a IOException.
closeAndReThrowUnchecked(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils
Call AutoCloseable.close() and re-throw any exceptions as an unchecked exception.
closeAndRethrowUnchecked(Closeable) - Static method in class io.servicetalk.transport.netty.internal.BuilderUtils
Call Closeable.close() and re-throw an unchecked exception if a checked exception is thrown.
closeAsync() - Method in interface io.servicetalk.client.api.AutoRetryStrategyProvider.AutoRetryStrategy
 
closeAsync() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
 
closeAsync() - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
 
closeAsync() - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
 
closeAsync() - Method in interface io.servicetalk.concurrent.api.AsyncCloseable
Used to close/shutdown a resource.
closeAsync() - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Closes all contained AsyncCloseables.
closeAsync() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
 
closeAsync() - Method in class io.servicetalk.concurrent.api.internal.OffloaderAwareExecutor
 
closeAsync() - Method in class io.servicetalk.concurrent.api.TestExecutor
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.RequestStreamingRoute
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.ResponseStreamingRoute
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.Route
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.StreamingRoute
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcService
 
closeAsync() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
 
closeAsync() - Method in interface io.servicetalk.http.api.HttpService
Closes this HttpService asynchronously.
closeAsync() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
 
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
 
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
closeAsync() - Method in interface io.servicetalk.http.api.StreamingHttpService
Closes this StreamingHttpService asynchronously.
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
 
closeAsync() - Method in class io.servicetalk.http.api.TestHttpServiceContext
 
closeAsync() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancer
 
closeAsync() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
closeAsync() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
closeAsync() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher
Attempts to close the configured Reporter.
closeAsync() - Method in interface io.servicetalk.transport.api.ConnectionAcceptor
 
closeAsync() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
 
closeAsync() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.ChannelSet
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
 
closeAsyncGracefully() - Method in interface io.servicetalk.concurrent.api.AsyncCloseable
Used to close/shutdown a resource, similar to AsyncCloseable.closeAsync(), but attempts to cleanup state before abruptly closing.
closeAsyncGracefully(AsyncCloseable, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.AsyncCloseables
Invokes AsyncCloseable.closeAsyncGracefully() on the closable, applies a timeout, and if the timeout fires forces a call to AsyncCloseable.closeAsync().
closeAsyncGracefully() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancer
 
closeAsyncGracefully() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
closeAsyncGracefully() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
closeAsyncGracefully() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher
Attempts to flush and close the configured Reporter.
closeAsyncGracefully() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.ChannelSet
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
 
closeClient() - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
closeClients() - Method in class io.servicetalk.http.api.AbstractHttpRequesterFilterTest
 
ClosedPartitionException - Exception in io.servicetalk.client.api.partition
Thrown when a request is issued against a valid partition that was closed after selection.
ClosedPartitionException(PartitionAttributes, String) - Constructor for exception io.servicetalk.client.api.partition.ClosedPartitionException
Create a new instance.
closeGracefully(Executor, GracefulAutoCloseable, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.AutoCloseables
Invokes GracefulAutoCloseable.closeGracefully() on the closable, applies a timeout, and if the timeout fires forces a call to AutoCloseable.close().
closeGracefully() - Method in interface io.servicetalk.concurrent.GracefulAutoCloseable
Used to close/shutdown a resource, similar to AutoCloseable.close(), but attempts to cleanup state before abruptly closing.
closeGracefully() - Method in interface io.servicetalk.http.api.HttpClient
 
closeGracefully() - Method in interface io.servicetalk.http.api.HttpConnection
 
closeGracefully() - Method in interface io.servicetalk.http.api.StreamingHttpClient
 
closeGracefully() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
 
closeGracefully() - Method in interface io.servicetalk.transport.api.ServerContext
 
CloseHandler - Class in io.servicetalk.transport.netty.internal
Contract between protocol codecs and a close handler.
CloseHandler() - Constructor for class io.servicetalk.transport.netty.internal.CloseHandler
 
CloseHandler.CloseEvent - Enum in io.servicetalk.transport.netty.internal
These events indicate an event was observed from the protocol or Channel that indicates the end of the Channel and no further requests should be attempted.
CloseHandler.CloseEventObservedException - Exception in io.servicetalk.transport.netty.internal
ClosedChannelException with additional meta-data to provide more context on what side initiated the close event.
closeIterator(Iterator<T>) - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIterable
Closes an Iterator as returned by Iterable.iterator() of the Iterable that is wrapped by this AbstractCloseableIterable.
closeServer() - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
code() - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns the status code.
code() - Method in class io.servicetalk.http.api.HttpResponseStatus
Get the three digit status-code indicating status of the response.
codeAsCharSequence() - Method in class io.servicetalk.http.api.HttpResponseStatus
Get the HttpResponseStatus.code() as a CharSequence.
Codec - Enum in io.servicetalk.opentracing.zipkin.publisher.reporter
Zipkin data formats for reporting of Spans.
codec(Codec) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Sets the Codec to encode the Spans with.
codec(Codec) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Sets the Codec to encode the Spans with.
collect(Supplier<? extends R>, BiFunction<? super R, ? super T, R>) - Method in class io.servicetalk.concurrent.api.Publisher
Collects all items emitted by this Publisher into a single item.
collectUnordered(Iterable<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnordered(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnordered(Iterable<? extends Single<? extends T>>, int) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnordered(int, Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnorderedDelayError(Iterable<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnorderedDelayError(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnorderedDelayError(Iterable<? extends Single<? extends T>>, int) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnorderedDelayError(int, Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
commit() - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
Commit configuring client security.
commit(KeyManagerFactory) - Method in interface io.servicetalk.grpc.api.GrpcServerSecurityConfigurator
Commit configuring server security.
commit(Supplier<InputStream>, Supplier<InputStream>) - Method in interface io.servicetalk.grpc.api.GrpcServerSecurityConfigurator
Commit configuring server security.
commit(Supplier<InputStream>, Supplier<InputStream>, String) - Method in interface io.servicetalk.grpc.api.GrpcServerSecurityConfigurator
Commit configuring server security.
commit(KeyManagerFactory) - Method in interface io.servicetalk.http.api.HttpServerSecurityConfigurator
Commit configuring server security.
commit(Supplier<InputStream>, Supplier<InputStream>) - Method in interface io.servicetalk.http.api.HttpServerSecurityConfigurator
Commit configuring server security.
commit(Supplier<InputStream>, Supplier<InputStream>, String) - Method in interface io.servicetalk.http.api.HttpServerSecurityConfigurator
Commit configuring server security.
commit() - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
Commit configuring client security.
commit() - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
Commit configuring client security.
compareTo(PartitionAttributes.Key) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key
 
Completable - Class in io.servicetalk.concurrent.api
An asynchronous computation that does not emit any data.
Completable() - Constructor for class io.servicetalk.concurrent.api.Completable
New instance.
CompletableOperator - Interface in io.servicetalk.concurrent.api
An operator contract for a Completable.
CompletableSource - Interface in io.servicetalk.concurrent
An asynchronous computation that does not emit any data.
CompletableSource.Processor - Interface in io.servicetalk.concurrent
A CompletableSource.Processor represents a processing stage that is both a CompletableSource and a CompletableSource.Subscriber and obeys the contracts of both.
CompletableSource.Subscriber - Interface in io.servicetalk.concurrent
Subscriber of the outcome of a Cancellable.
complete() - Static method in class io.servicetalk.concurrent.internal.TerminalNotification
Returns a TerminalNotification for completion.
completed() - Static method in class io.servicetalk.concurrent.api.Completable
Creates a realized completed Completable.
COMPLETED - Static variable in class io.servicetalk.transport.netty.internal.ContextFilterSuccessful
 
completedStageResponse() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
CompositeBuffer - Interface in io.servicetalk.buffer.api
A virtual Buffer which shows multiple buffers as a single merged buffer.
CompositeCloseable - Interface in io.servicetalk.concurrent.api
A AsyncCloseable and Closeable that allows for adding new AsyncCloseables till it is closed.
COMPRESS - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"compress"
computeFlushStrategy(FlushStrategy, boolean) - Method in interface io.servicetalk.transport.netty.internal.NettyConnectionContext.FlushStrategyProvider
Given the current FlushStrategy associated with this NettyConnectionContext, return a new FlushStrategy.
concat(Completable) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to next Completable and propagate its terminal signal to the returned Completable.
concat(Single<? extends T>) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to next Single and propagate the result to the returned Single.
concat(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to next Publisher and propagate all emissions to the returned Publisher.
concat(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Publisher
Emits items emitted by next Publisher after this Publisher terminates successfully.
concat(Single<? extends T>) - Method in class io.servicetalk.concurrent.api.Publisher
Listens and emits the result of next Single after this Publisher terminates successfully.
concat(Completable) - Method in class io.servicetalk.concurrent.api.Publisher
Listens for completion of next Completable after this Publisher terminates successfully.
concat(Single<? extends T>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Publisher that first emits the result of this Single and then subscribes and emits result of next Single.
concat(Completable) - Method in class io.servicetalk.concurrent.api.Single
Returns a Single that emits the result of this Single after next Completable terminates successfully.
concat(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Publisher that first emits the result of this Single and then subscribes and emits all elements from next Publisher.
ConcurrentCompletableSubscriberFunction - Class in io.servicetalk.concurrent.api
Allows multiple CompletableSource.Subscribers to be concurrently subscribed to a TestCompletable, and multicasts signals to them all.
ConcurrentCompletableSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.ConcurrentCompletableSubscriberFunction
 
ConcurrentPublisherSubscriberFunction<T> - Class in io.servicetalk.concurrent.api
Allows multiple PublisherSource.Subscribers to be concurrently subscribed to a TestPublisher, and multicasts signals to them all.
ConcurrentPublisherSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.ConcurrentPublisherSubscriberFunction
 
ConcurrentSingleSubscriberFunction<T> - Class in io.servicetalk.concurrent.api
Allows multiple SingleSource.Subscribers to be concurrently subscribed to a TestSingle, and multicasts signals to them all.
ConcurrentSingleSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.ConcurrentSingleSubscriberFunction
 
concurrentSubscribers() - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Allow concurrent subscribers.
concurrentSubscribers(ConcurrentCompletableSubscriberFunction) - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Allow concurrent subscribers, with the specified ConcurrentCompletableSubscriberFunction.
concurrentSubscribers() - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Allow concurrent subscribers.
concurrentSubscribers(ConcurrentPublisherSubscriberFunction<T>) - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Allow concurrent subscribers, with the specified ConcurrentPublisherSubscriberFunction.
concurrentSubscribers() - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Allow concurrent subscribers.
concurrentSubscribers(ConcurrentSingleSubscriberFunction<T>) - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Allow concurrent subscribers, with the specified ConcurrentSingleSubscriberFunction.
ConcurrentSubscription - Class in io.servicetalk.concurrent.internal
This class prevents concurrent invocation of PublisherSource.Subscription methods and preserves the Reactive Streams, 2.7 rule when there is a possibility of concurrency.
ConcurrentSubscription(PublisherSource.Subscription) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentSubscription
New instance.
ConcurrentTerminalSubscriber<T> - Class in io.servicetalk.concurrent.internal
A PublisherSource.Subscriber that allows for concurrent delivery of terminal events.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T>) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Create a new instance.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T>, boolean) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Create a new instance.
ConcurrentUtils - Class in io.servicetalk.concurrent.internal
Utilities which can be used for concurrency.
ConditionalFilterFactory - Class in io.servicetalk.http.api
 
ConditionalFilterFactory(Predicate<StreamingHttpRequest>, ConditionalFilterFactory.FilterFactory) - Constructor for class io.servicetalk.http.api.ConditionalFilterFactory
 
ConditionalFilterFactory.FilterFactory - Interface in io.servicetalk.http.api
 
config() - Method in class io.servicetalk.tcp.netty.internal.TcpClient
Returns configuration for this client.
configure(FeatureContext) - Method in class io.servicetalk.data.jackson.jersey.config.ServiceTalkJacksonSerializerAutoDiscoverable
 
configure(FeatureContext) - Method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature
 
configure(FeatureContext) - Method in class io.servicetalk.http.router.jersey.config.ServiceTalkAutoDiscoverable
 
configure(FeatureContext) - Method in class io.servicetalk.http.router.jersey.ServiceTalkFeature
 
configureBuilders(HttpServerBuilder, HttpJerseyRouterBuilder) - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
configureBuilders(HttpServerBuilder, HttpJerseyRouterBuilder) - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest
 
configureBuilders(HttpServerBuilder, HttpJerseyRouterBuilder) - Method in class io.servicetalk.http.router.jersey.ExecutionStrategyTest
 
configureBuilders(HttpServerBuilder, HttpJerseyRouterBuilder) - Method in class io.servicetalk.http.router.jersey.MixedModeResourceTest
 
configureForPartition(PartitionAttributes, SingleAddressHttpClientBuilder<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator
Configures the passed SingleAddressHttpClientBuilder for a given set of PartitionAttributes.
conflict() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.CONFLICT response.
conflict() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.CONFLICT response.
CONFLICT - Static variable in class io.servicetalk.http.api.HttpResponseStatus
409 Conflict
conflict() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.CONFLICT response.
conflictingAnnotations() - Method in class io.servicetalk.http.router.jersey.resources.ExecutionStrategyResources.ResourceInvalidExecStrategy
 
connect() - Method in class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
Connects this OutputStream to the returned Publisher such that any data written to this OutputStream is eventually delivered to a PublisherSource.Subscriber of the returned Publisher.
connect() - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
Connects this PayloadWriter to the returned Publisher such that any data written to this PayloadWriter is eventually delivered to a PublisherSource.Subscriber of the returned Publisher.
connect(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory
Create a new HttpRequestMethod.CONNECT request.
connect(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory
Create a new HttpRequestMethod.CONNECT request.
CONNECT - Static variable in class io.servicetalk.http.api.HttpRequestMethod
HTTP CONNECT method.
connect(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory
Create a new HttpRequestMethod.CONNECT request.
connect(ExecutionContext, SocketAddress) - Method in class io.servicetalk.tcp.netty.internal.TcpClient
Connect to the passed address.
connect(SocketAddress, Object, ReadOnlyTcpClientConfig, boolean, ExecutionContext, Function<Channel, Single<? extends C>>) - Static method in class io.servicetalk.tcp.netty.internal.TcpConnector
Connects to the passed resolvedRemoteAddress address, resolving the address, if required.
CONNECT_TIMEOUT - Static variable in class io.servicetalk.transport.api.ServiceTalkSocketOptions
The connect timeout in milliseconds.
ConnectableBufferOutputStream - Class in io.servicetalk.concurrent.api.internal
An OutputStream that can be connected to a sink such that any data written on the OutputStream is eventually emitted to the connected Publisher PublisherSource.Subscriber.
ConnectableBufferOutputStream(BufferAllocator) - Constructor for class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
Creates a new instance.
ConnectablePayloadWriter<T> - Class in io.servicetalk.concurrent.api.internal
A PayloadWriter that can be connected to a sink such that any data written on the PayloadWriter is eventually emitted to the connected Publisher PublisherSource.Subscriber.
ConnectablePayloadWriter() - Constructor for class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
 
connectBlocking(ExecutionContext, SocketAddress) - Method in class io.servicetalk.tcp.netty.internal.TcpClient
Connect and await for the connection.
CONNECTION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"connection"
ConnectionAcceptor - Interface in io.servicetalk.transport.api
A contract that defines the connection acceptance criterion.
ConnectionAcceptorFactory - Interface in io.servicetalk.transport.api
ConnectionClosedException - Exception in io.servicetalk.client.api
Thrown when the connection is no longer available.
ConnectionClosedException(String) - Constructor for exception io.servicetalk.client.api.ConnectionClosedException
Creates a new instance.
ConnectionClosedException(String, Throwable) - Constructor for exception io.servicetalk.client.api.ConnectionClosedException
Creates a new instance.
connectionContext() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
connectionContext() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
connectionContext() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpConnection
connectionContext() - Method in interface io.servicetalk.http.api.HttpConnection
connectionContext() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
 
connectionContext() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
ConnectionContext - Interface in io.servicetalk.transport.api
A context for a connection.
ConnectionContext.Protocol - Interface in io.servicetalk.transport.api
Provides information about the network protocol.
ConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> - Interface in io.servicetalk.client.api
A factory for creating new connections.
ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> - Interface in io.servicetalk.client.api
A contract to decorate ConnectionFactory instances for the purpose of filtering.
ConnectionRejectedException - Exception in io.servicetalk.client.api
Thrown when a newly created connection was rejected.
ConnectionRejectedException(String) - Constructor for exception io.servicetalk.client.api.ConnectionRejectedException
Creates a new instance.
ConnectionRejectedException(String, Throwable) - Constructor for exception io.servicetalk.client.api.ConnectionRejectedException
Creates a new instance.
ConnectTimeoutException - Exception in io.servicetalk.client.api
Throws when a connect operations failed because of a timeout.
ConnectTimeoutException(String, Throwable) - Constructor for exception io.servicetalk.client.api.ConnectTimeoutException
Create a new instance.
connectWithFdBlocking(ExecutionContext, SocketAddress) - Method in class io.servicetalk.tcp.netty.internal.TcpClient
Connect using a FileDescriptorSocketAddress and await for the connection.
consolidate() - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Consolidate the composed Buffers.
consolidate(int, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Consolidate the composed Buffers.
ConsumableEvent<T> - Interface in io.servicetalk.client.api
A container for an event that requires acknowledgement when the event is consumed via ConsumableEvent.eventConsumed().
consume(ProcessorSignalsConsumer<T>) - Method in interface io.servicetalk.concurrent.api.BlockingProcessorSignalsHolder
Consumes the next item stored in this holder.
consume(ProcessorSignalsConsumer<T>, long, TimeUnit) - Method in interface io.servicetalk.concurrent.api.BlockingProcessorSignalsHolder
Consumes the next item stored in this holder.
consumeItem(T) - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer
Consumes the passed item.
consumeTerminal(Throwable) - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer
Consumes the Throwable that terminated the holder.
consumeTerminal() - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer
Consumes the termination of the holder.
contains(PartitionAttributes.Key<T>) - Method in interface io.servicetalk.client.api.partition.PartitionAttributes
Determine if there is a value associated with key.
contains(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
contains(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns true if a header with the name exists, false otherwise.
contains(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns true if a header with the name and value exists, false otherwise.
contains(int) - Method in enum io.servicetalk.http.api.HttpResponseStatus.StatusClass
Determine if code falls into this HttpResponseStatus.StatusClass.
contains(HttpResponseStatus) - Method in enum io.servicetalk.http.api.HttpResponseStatus.StatusClass
Determine if status code falls into this HttpResponseStatus.StatusClass.
containsIgnoreCase(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
containsIgnoreCase(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns true if a header with the name and value exists, false otherwise.
containsKey(AsyncContextMap.Key<?>) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to determine if the current context contains a key/value entry corresponding to key.
containsKey(AsyncContextMap.Key<?>) - Method in interface io.servicetalk.concurrent.api.AsyncContextMap
Determine if this context contains a key/value entry corresponding to key.
containsKey(String) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
containsKey(String) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
content() - Method in interface io.servicetalk.buffer.api.BufferHolder
The buffer contained by this object.
CONTENT_BASE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-base"
CONTENT_DISPOSITION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-disposition"
CONTENT_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-encoding"
CONTENT_LANGUAGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-language"
CONTENT_LENGTH - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-length"
CONTENT_LOCATION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-location"
CONTENT_MD5 - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-md5"
CONTENT_RANGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-range"
CONTENT_SECURITY_POLICY - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-security-policy"
CONTENT_TRANSFER_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-transfer-encoding"
CONTENT_TYPE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-type"
contentEquals(CharSequence, CharSequence) - Static method in class io.servicetalk.http.api.CharSequences
Returns true if the content of both CharSequence's are equals.
contentEqualsIgnoreCase(CharSequence, CharSequence) - Static method in class io.servicetalk.http.api.CharSequences
Perform a case-insensitive comparison of two CharSequences.
contentEqualTo(CharSequence) - Static method in class io.servicetalk.http.api.Matchers
ContentReadException(String, Throwable) - Constructor for exception io.servicetalk.http.router.jersey.TestUtils.ContentReadException
 
context() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpan
 
ContextFilterSuccessful - Class in io.servicetalk.transport.netty.internal
Netty pipeline event that represents the successful completion of the ConnectionAcceptor.
contextResolverFor(ObjectMapper) - Static method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature
Create a new ContextResolver for JacksonSerializationProvider used by this feature.
contextResolverFor(JacksonSerializationProvider) - Static method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature
Create a new ContextResolver for JacksonSerializationProvider used by this feature.
CONTINUE - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"100-continue"
CONTINUE - Static variable in class io.servicetalk.http.api.HttpResponseStatus
100 Continue
continueResponse() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.CONTINUE response.
continueResponse() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.CONTINUE response.
continueResponse() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.CONTINUE response.
COOKIE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"cookie"
cookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
Get the current value for HttpHeaderNames.COOKIE.
cookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator
Get the current value for HttpHeaderNames.COOKIE.
CookieMatcher - Interface in io.servicetalk.http.router.predicate.dsl
Methods for route matching on cookies.
CookiesByNameIterator(CharSequence) - Constructor for class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
Create a new instance.
CookiesIterator() - Constructor for class io.servicetalk.http.api.HeaderUtils.CookiesIterator
 
copy() - Method in interface io.servicetalk.buffer.api.Buffer
Returns a copy of this buffer's readable bytes.
copy(int, int) - Method in interface io.servicetalk.buffer.api.Buffer
Returns a copy of this buffer's sub-region.
copy() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
copy(int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
copy() - Method in interface io.servicetalk.concurrent.api.AsyncContextMap
Create an isolated copy of the current map.
copy() - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Creates a deep copy of this StrategyInfluencerChainBuilder.
CopyByteBufHandlerChannelInitializer - Class in io.servicetalk.transport.netty.internal
Initializer to configure ChannelInboundHandler that will ensure no pooled ByteBufs are passed to the user and so no leaks are produced if the user does not call ReferenceCountUtil.release(Object).
CopyByteBufHandlerChannelInitializer(ByteBufAllocator) - Constructor for class io.servicetalk.transport.netty.internal.CopyByteBufHandlerChannelInitializer
Creates a new instance.
create(ConnectionFactory<ResolvedAddress, C>) - Method in interface io.servicetalk.client.api.ConnectionFactoryFilter
Decorates the passed original ConnectionFactory to add the filtering logic.
create(ConnectionFactory<ResolvedAddress, C>) - Method in class io.servicetalk.client.api.LimitingConnectionFactoryFilter
 
create(FilterableClient) - Method in interface io.servicetalk.grpc.api.GrpcClientFilterFactory
Create a Filter using the provided Filter.
create(Service) - Method in interface io.servicetalk.grpc.api.GrpcServiceFilterFactory
Create a Filter using the provided Service.
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.api.ConditionalFilterFactory
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.api.ConditionalFilterFactory
 
create(U, FilterableStreamingHttpClient) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory
Create a StreamingHttpClientFilter for the passed address using the provided FilterableStreamingHttpClient.
create(FilterableStreamingHttpClient) - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory
create(FilterableStreamingHttpConnection) - Method in interface io.servicetalk.http.api.StreamingHttpConnectionFilterFactory
create(StreamingHttpService) - Method in interface io.servicetalk.http.api.StreamingHttpServiceFilterFactory
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.RetryingHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.RetryingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.opentracing.http.TracingHttpServiceFilter
 
create(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory
Create a ConnectionAcceptor using the provided ConnectionAcceptor.
created() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.CREATED response.
created() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.CREATED response.
CREATED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
201 Created
created() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.CREATED response.
createEventLoopGroup(int, ThreadFactory) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new EventLoopGroup.
createFilter(FF) - Method in class io.servicetalk.http.api.AbstractHttpRequesterFilterTest
Creates filter with default OK request handlers.
createFilter(AbstractHttpRequesterFilterTest.RequestHandler, FF) - Method in class io.servicetalk.http.api.AbstractHttpRequesterFilterTest
Creates filter with provided request handler.
createFilter(AbstractHttpRequesterFilterTest.RequestHandler, AbstractHttpRequesterFilterTest.RequestWithContextHandler, FF) - Method in class io.servicetalk.http.api.AbstractHttpRequesterFilterTest
Creates filter with provided request handlers.
createFilter(AbstractHttpRequesterFilterTest.RequestHandler, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.AbstractHttpServiceFilterTest
 
createIoExecutor(ThreadFactory) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor with the default number of ioThreads.
createIoExecutor(int, ThreadFactory) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor.
createIoExecutor(int, ThreadFactory) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(int) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(ThreadFactory) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the default number of ioThreads.
createIoExecutor() - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the default number of ioThreads.
createRunnerForTestWithParameters(TestWithParameters) - Method in class io.servicetalk.http.api.MixinAwareParametersRunnerFactory
 
cumulationReset() - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Resets cumulation.
current() - Static method in class io.servicetalk.concurrent.api.AsyncContext
Get the current AsyncContextMap.
currentMillis() - Method in class io.servicetalk.concurrent.api.TestExecutor
Returns the internal clock time in milliseconds.
currentNanos() - Method in class io.servicetalk.concurrent.api.TestExecutor
Returns the internal clock time in nanoseconds.
currentStrategy() - Method in class io.servicetalk.transport.netty.internal.FlushStrategyHolder
Returns the current value of the enclosed FlushStrategy.
currentTime(TimeUnit) - Method in class io.servicetalk.concurrent.api.TestExecutor
Returns the internal clock time in the specified unit.
customResponseStatus() - Method in class io.servicetalk.http.router.jersey.SynchronousResourceTest
 
customStrategyBuilder() - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies
A GrpcExecutionStrategy that disables all offloads.
customStrategyBuilder() - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
A HttpExecutionStrategy that disables all offloads.

D

data() - Static method in class io.servicetalk.http.router.jersey.AbstractJerseyStreamingHttpServiceTest
Some test classes eg.
data() - Static method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
data() - Static method in class io.servicetalk.http.router.jersey.AbstractResourceTest
 
data() - Static method in class io.servicetalk.http.router.jersey.ExecutionStrategyTest
 
datagramChannel(EventLoopGroup) - Static method in class io.servicetalk.transport.netty.internal.BuilderUtils
Returns the correct Class to use with the given EventLoopGroup.
DATE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"date"
decode(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Decode the from one ByteBuf to an other.
decodeLast(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Is called one last time when the ChannelHandlerContext goes in-active.
DEFAULT_ALLOCATOR - Static variable in class io.servicetalk.buffer.netty.BufferAllocators
Default BufferAllocator whose Buffers are typically backed by Netty buffers.
DEFAULT_HEADER_FILTER - Static variable in class io.servicetalk.http.api.HeaderUtils
 
DEFAULT_NAME_PREFIX - Static variable in class io.servicetalk.concurrent.api.DefaultThreadFactory
 
DEFAULT_RO_ALLOCATOR - Static variable in class io.servicetalk.buffer.api.ReadOnlyBufferAllocators
Default BufferAllocator that creates Buffer instances which cannot be modified and are read only.
DEFAULT_TIMEOUT_SECONDS - Static variable in class io.servicetalk.concurrent.internal.ServiceTalkTestTimeout
 
DefaultAutoRetryStrategyProvider - Class in io.servicetalk.client.api
Default implementation for AutoRetryStrategyProvider.
DefaultAutoRetryStrategyProvider.Builder - Class in io.servicetalk.client.api
DefaultDnsServiceDiscovererBuilder - Class in io.servicetalk.dns.discovery.netty
Builder for DNS ServiceDiscoverer which will attempt to resolve A, AAAA, CNAME, and SRV type queries.
DefaultDnsServiceDiscovererBuilder() - Constructor for class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
 
DefaultExecutionContext - Class in io.servicetalk.transport.api
A default implementation of ExecutionContext.
DefaultExecutionContext(BufferAllocator, IoExecutor, Executor, ExecutionStrategy) - Constructor for class io.servicetalk.transport.api.DefaultExecutionContext
Create a new instance.
defaultFlushStrategy() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
defaultFlushStrategy() - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
Creates a default FlushStrategy.
defaultFlushStrategy() - Method in interface io.servicetalk.transport.netty.internal.NettyConnectionContext
Returns the FlushStrategy used by default for this NettyConnectionContext.
DefaultGroupKey<Address> - Class in io.servicetalk.client.api
A default implementation of GroupKey.
DefaultGroupKey(Address, ExecutionContext) - Constructor for class io.servicetalk.client.api.DefaultGroupKey
Create a new instance.
DefaultGrpcClientMetadata - Class in io.servicetalk.grpc.api
Default implementation for DefaultGrpcClientMetadata.
DefaultGrpcClientMetadata(String) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Creates a new instance.
DefaultGrpcClientMetadata(String, GrpcExecutionStrategy) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Creates a new instance.
DefaultHttpCookiePair - Class in io.servicetalk.http.api
Default implementation of HttpCookiePair.
DefaultHttpCookiePair(CharSequence, CharSequence) - Constructor for class io.servicetalk.http.api.DefaultHttpCookiePair
Create a new instance.
DefaultHttpCookiePair(CharSequence, CharSequence, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpCookiePair
Create a new instance.
DefaultHttpExecutionContext - Class in io.servicetalk.http.api
Default implementation of HttpExecutionContext.
DefaultHttpExecutionContext(BufferAllocator, IoExecutor, Executor, HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.DefaultHttpExecutionContext
Create a new instance.
DefaultHttpHeadersFactory - Class in io.servicetalk.http.api
Default implementation of HttpHeadersFactory.
DefaultHttpHeadersFactory(boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory
Create an instance of the factory with the default array size hint.
DefaultHttpHeadersFactory(boolean, boolean, int, int) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory
Create an instance of the factory.
DefaultHttpLoadBalancerFactory<ResolvedAddress> - Class in io.servicetalk.http.netty
Default implementation of HttpLoadBalancerFactory.
DefaultHttpLoadBalancerFactory.Builder<ResolvedAddress> - Class in io.servicetalk.http.netty
A builder for creating instances of DefaultHttpLoadBalancerFactory.
DefaultHttpSetCookie - Class in io.servicetalk.http.api
Default implementation of HttpSetCookie.
DefaultHttpSetCookie(CharSequence, CharSequence) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie
Create a new not wrapped, not secure and not HTTP-only HttpSetCookie instance, with no path, domain, expire date and maximum age.
DefaultHttpSetCookie(CharSequence, CharSequence, boolean, boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie
Create a new HttpSetCookie instance, with no path, domain, expire date and maximum age.
DefaultHttpSetCookie(CharSequence, CharSequence, CharSequence, CharSequence, CharSequence, Long, HttpSetCookie.SameSite, boolean, boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie
Creates a new HttpSetCookie instance.
defaultInitializer() - Static method in interface io.servicetalk.transport.netty.internal.ChannelInitializer
DefaultInMemoryTracer - Class in io.servicetalk.opentracing.inmemory
Tracer implementation that propagates spans in-memory and emits events to listeners.
DefaultInMemoryTracer.Builder - Class in io.servicetalk.opentracing.inmemory
Builders for DefaultInMemoryTracer.
DefaultInMemoryTraceState - Class in io.servicetalk.opentracing.inmemory
Default implementation of InMemoryTraceState.
DefaultInMemoryTraceState(String, String, String, boolean) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemoryTraceState
Constructs an instance.
defaultInvalidateHostsOnDnsFailurePredicate() - Static method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
DefaultNettyConnection<Read,Write> - Class in io.servicetalk.transport.netty.internal
Implementation of NettyConnection backed by a netty Channel.
defaultOffloaderFactory() - Static method in class io.servicetalk.concurrent.internal.SignalOffloaders
Return a default SignalOffloaderFactory.
DefaultPartitionAttributesBuilder - Class in io.servicetalk.client.api.internal.partition
Default implementation of PartitionAttributesBuilder.
DefaultPartitionAttributesBuilder(int) - Constructor for class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
Create a new instance.
DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api.internal
An implementation of ClientGroup that can be used for partitioned client use-cases where PartitionAttributes are discovered through PartitionedServiceDiscovererEvents.
DefaultPartitionedClientGroup(Function<PartitionAttributes, Client>, Function<PartitionAttributes, Client>, DefaultPartitionedClientGroup.PartitionedClientFactory<U, R, Client>, PartitionMapFactory, Publisher<? extends PartitionedServiceDiscovererEvent<R>>, int) - Constructor for class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
Creates a new instance.
DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> - Interface in io.servicetalk.client.api.internal
Factory for building partitioned clients.
defaultRetryForPredicate() - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder
DefaultRouteExecutionStrategyFactory<ES extends ExecutionStrategy> - Class in io.servicetalk.router.utils.internal
Implementation of RouteExecutionStrategyFactory that always throws IllegalArgumentException.
defaultSecurityContext() - Method in class io.servicetalk.http.router.jersey.SecurityFilterTest
 
defaultSecurityContext() - Method in class io.servicetalk.http.router.jersey.SynchronousResourceTest
 
DefaultSerializer - Class in io.servicetalk.serialization.api
Default implementation for Serializer.
DefaultSerializer(SerializationProvider) - Constructor for class io.servicetalk.serialization.api.DefaultSerializer
New instance.
DefaultServiceDiscovererEvent<T> - Class in io.servicetalk.client.api
Default implementation of ServiceDiscovererEvent.
DefaultServiceDiscovererEvent(T, boolean) - Constructor for class io.servicetalk.client.api.DefaultServiceDiscovererEvent
Create a new instance.
defaultStrategy() - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies
defaultStrategy(Executor) - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies
The default GrpcExecutionStrategy using the passed Executor.
defaultStrategy() - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
defaultStrategy(Executor) - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
The default HttpExecutionStrategy using the passed Executor.
defaultStrategyFactory() - Static method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory
DefaultStreamingHttpRequestResponseFactory - Class in io.servicetalk.http.api
DefaultStreamingHttpRequestResponseFactory(BufferAllocator, HttpHeadersFactory, HttpProtocolVersion) - Constructor for class io.servicetalk.http.api.DefaultStreamingHttpRequestResponseFactory
Create a new instance.
defaultStreamingInfluencer() - Static method in interface io.servicetalk.http.api.HttpExecutionStrategyInfluencer
Returns an HttpExecutionStrategyInfluencer to be used for the default streaming programming model.
DefaultTestCerts - Class in io.servicetalk.test.resources
Provides a set of certificates useful for tests that require SSL.
DefaultThreadFactory - Class in io.servicetalk.concurrent.api
A ThreadFactory implementation.
DefaultThreadFactory() - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance that creates daemon threads with Thread.NORM_PRIORITY priority.
DefaultThreadFactory(boolean) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance that creates threads with Thread.NORM_PRIORITY priority.
DefaultThreadFactory(int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance that creates daemon threads.
DefaultThreadFactory(String) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
Create a new instance.
DefaultThreadFactory(boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance.
DefaultThreadFactory(String, boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance.
defer(Supplier<? extends Completable>) - Static method in class io.servicetalk.concurrent.api.Completable
Defer creation of a Completable till it is subscribed to.
defer(Supplier<? extends Publisher<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Publisher
Defers creation of a Publisher till it is subscribed.
defer(Supplier<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Defer creation of a Single till it is subscribed to.
DeferredEmptySubscription - Class in io.servicetalk.concurrent.api
DeferredEmptySubscription(PublisherSource.Subscriber<?>, TerminalNotification) - Constructor for class io.servicetalk.concurrent.api.DeferredEmptySubscription
New instance.
DeferSslHandler - Class in io.servicetalk.transport.netty.internal
A ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler.
DEFLATE - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"deflate"
DelayedCancellable - Class in io.servicetalk.concurrent.internal
A Cancellable which serves as a placeholder until the "real" Cancellable is available.
DelayedCancellable() - Constructor for class io.servicetalk.concurrent.internal.DelayedCancellable
 
delayedCancellable(Cancellable) - Method in class io.servicetalk.concurrent.internal.DelayedCancellable
Set the delayed Cancellable.
delayedStageResponse() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
DelayedSubscription - Class in io.servicetalk.concurrent.internal
A PublisherSource.Subscription which serves as a placeholder until the "real" PublisherSource.Subscription is available.
DelayedSubscription() - Constructor for class io.servicetalk.concurrent.internal.DelayedSubscription
 
delayedSubscription(PublisherSource.Subscription) - Method in class io.servicetalk.concurrent.internal.DelayedSubscription
delegate() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
Returns the ConnectionFactory delegate.
delegate() - Method in class io.servicetalk.http.api.DelegatingHttpConnectionContext
Get the HttpConnectionContext that this class delegates to.
delegate() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
Get the ReservedStreamingHttpConnection this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
Get the FilterableStreamingHttpClient this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
Get the FilterableStreamingHttpConnection this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
Returns StreamingHttpService to which all calls are delegated.
delegate() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
The ConnectionAcceptor to which all calls are delegated to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
Get the ConnectionContext that this class delegates to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
Get the ExecutionContext that this class delegates to.
delegate() - Method in class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy
Returns the delegate FlushStrategy used.
DelegatingConnectionAcceptor - Class in io.servicetalk.transport.api
An implementation of ConnectionAcceptor that delegates all methods to another ConnectionAcceptor.
DelegatingConnectionAcceptor(ConnectionAcceptor) - Constructor for class io.servicetalk.transport.api.DelegatingConnectionAcceptor
New instance.
DelegatingConnectionContext - Class in io.servicetalk.transport.api
A ConnectionContext implementation that delegates all calls to a provided ConnectionContext.
DelegatingConnectionContext(ConnectionContext) - Constructor for class io.servicetalk.transport.api.DelegatingConnectionContext
New instance.
DelegatingConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api
A ConnectionFactory that delegates all methods to another ConnectionFactory.
DelegatingConnectionFactory(ConnectionFactory<ResolvedAddress, C>) - Constructor for class io.servicetalk.client.api.DelegatingConnectionFactory
Create a new instance.
DelegatingExecutionContext - Class in io.servicetalk.transport.api
An ExecutionContext implementation that delegates all calls to a provided ExecutionContext.
DelegatingExecutionContext(ExecutionContext) - Constructor for class io.servicetalk.transport.api.DelegatingExecutionContext
New instance.
DelegatingExecutor - Class in io.servicetalk.concurrent.api
An Executor that simply delegates all calls to another Executor.
DelegatingExecutor(Executor) - Constructor for class io.servicetalk.concurrent.api.DelegatingExecutor
New instance.
DelegatingFlushStrategy - Class in io.servicetalk.transport.netty.internal
A FlushStrategy implementation that delegates all calls to another FlushStrategy.
DelegatingFlushStrategy(FlushStrategy) - Constructor for class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy
Create a new instance.
DelegatingHttpConnectionContext - Class in io.servicetalk.http.api
HttpConnectionContext implementation that delegates all calls to a provided HttpConnectionContext.
DelegatingHttpConnectionContext(HttpConnectionContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpConnectionContext
New instance.
DelegatingHttpExecutionContext - Class in io.servicetalk.http.api
An implementation of HttpExecutionContext that delegates all method calls to another HttpExecutionContext.
DelegatingHttpExecutionContext(HttpExecutionContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpExecutionContext
Creates a new instance.
DelegatingHttpExecutionStrategy - Class in io.servicetalk.http.api
An HttpExecutionStrategy that delegates all method calls to another HttpExecutionStrategy.
DelegatingHttpExecutionStrategy(HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.DelegatingHttpExecutionStrategy
Create a new instance.
DelegatingHttpServiceContext - Class in io.servicetalk.http.api
An implementation of HttpServiceContext that delegates all calls to a provided HttpServiceContext.
DelegatingHttpServiceContext(HttpServiceContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpServiceContext
New instance.
DelegatingSignalOffloader - Class in io.servicetalk.concurrent.internal
A SignalOffloader that delegates all calls to another SignalOffloader.
DelegatingSignalOffloader(SignalOffloader) - Constructor for class io.servicetalk.concurrent.internal.DelegatingSignalOffloader
Create a new instance.
DelegatingSignalOffloaderFactory - Class in io.servicetalk.concurrent.internal
A SignalOffloaderFactory that delegates all calls to another SignalOffloaderFactory.
DelegatingSignalOffloaderFactory(SignalOffloaderFactory) - Constructor for class io.servicetalk.concurrent.internal.DelegatingSignalOffloaderFactory
Create a new instance.
delete(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory
Create a new HttpRequestMethod.DELETE request.
delete(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory
Create a new HttpRequestMethod.DELETE request.
DELETE - Static variable in class io.servicetalk.http.api.HttpRequestMethod
HTTP DELETE method.
delete(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory
Create a new HttpRequestMethod.DELETE request.
DELIBERATE_EXCEPTION - Static variable in exception io.servicetalk.concurrent.internal.DeliberateException
 
DeliberateException - Exception in io.servicetalk.concurrent.internal
 
DeliberateException() - Constructor for exception io.servicetalk.concurrent.internal.DeliberateException
 
deliverCompleteFromSource(PublisherSource.Subscriber<T>) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal complete to a PublisherSource.Subscriber that has not yet had PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) called.
deliverCompleteFromSource(CompletableSource.Subscriber) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal complete to a CompletableSource.Subscriber that has not yet had CompletableSource.Subscriber#onSubscribe(Cancellable) called.
deliverErrorFromSource(PublisherSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
deliverErrorFromSource(SingleSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal error to a SingleSource.Subscriber that has not yet had SingleSource.Subscriber#onSubscribe(Cancellable) called.
deliverErrorFromSource(CompletableSource.Subscriber, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal error to a CompletableSource.Subscriber that has not yet had CompletableSource.Subscriber#onSubscribe(Cancellable) called.
deliverSuccessFromSource(SingleSource.Subscriber<T>, T) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Invokes SingleSource.Subscriber#onSuccess(Object) ignoring an occurred exception if any.
DemandCheckingSubscriber<T> - Class in io.servicetalk.concurrent.api
A PublisherSource.Subscriber that wraps another, and asserts that items are not delivered without sufficient demand.
DemandCheckingSubscriber(PublisherSource.Subscriber<? super T>) - Constructor for class io.servicetalk.concurrent.api.DemandCheckingSubscriber
Create a new DemandCheckingSubscriber that delegates to delegate.
DemandCheckingSubscriberFunction<T> - Class in io.servicetalk.concurrent.api
DemandCheckingSubscriberFunction() - Constructor for class io.servicetalk.concurrent.api.DemandCheckingSubscriberFunction
 
description() - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns additional descriptions, can be null.
deserialize(HttpHeaders, Buffer) - Method in interface io.servicetalk.http.api.HttpDeserializer
Deserialize a single Object into a T.
deserialize(HttpHeaders, BlockingIterable<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer
Deserialize a BlockingIterable of Objects into a BlockingIterable of type T.
deserialize(HttpHeaders, Publisher<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer
Deserialize a Publisher of Objects into a Publisher of type T.
deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserialize(Publisher<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserialize(Iterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserialize(BlockingIterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Applies a deserializer on the passed Publisher to convert into a Publisher of deserialized instances of T.
deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Applies a deserializer on the passed Iterable to convert into a Iterable of deserialized instances of T.
deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Applies a deserializer on the passed BlockingIterable to convert into a BlockingIterable of deserialized instances of T.
deserialize(Publisher<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Applies a deserializer on the passed Publisher to convert into a Publisher of deserialized instances of T.
deserialize(Iterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Applies a deserializer on the passed Iterable to convert into a CloseableIterable of deserialized instances of T.
deserialize(BlockingIterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Applies a deserializer on the passed BlockingIterable to convert into a Iterable of deserialized instances of T.
deserialize(Buffer) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
Deserialize the passed Buffer into an Iterable of Ts.
deserialize(Iterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
Deserialize the passed Iterable of Buffers into an Iterable of Ts.
deserialize(BlockingIterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
Deserialize the passed BlockingIterable of Buffers into a BlockingIterable of Ts.
deserializeAggregated(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserializeAggregated(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserializeAggregated(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deserializes the passed encoded Buffer to one or more instances of T.
deserializeAggregated(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deserializes the passed encoded Buffer to zero or more instances of T.
deserializeAggregatedSingle(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
 
deserializeAggregatedSingle(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deserializes the passed encoded Buffer to a single instance of T.
deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deserializes the passed encoded Buffer to a single instance of T.
deserializerFor(GrpcMessageEncoding, Class<T>) - Method in interface io.servicetalk.grpc.api.GrpcSerializationProvider
Get a HttpDeserializer for a Class of type T.
deserializerFor(Class<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider
Get a HttpDeserializer for a Class of type T.
deserializerFor(TypeHolder<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider
Get a HttpDeserializer for a TypeHolder of type T.
detectBoundary(Object) - Method in interface io.servicetalk.transport.netty.internal.SplittingFlushStrategy.FlushBoundaryProvider
Detect the SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for the passed itemWritten.
difference(Executor, HttpExecutionStrategy, HttpExecutionStrategy) - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
Find the difference between two strategies and provide a resulting strategy if there are differences in between the strategies.
disable() - Static method in class io.servicetalk.concurrent.api.AsyncContext
Disable AsyncContext.
DISABLE_AUTO_RETRIES - Static variable in interface io.servicetalk.client.api.AutoRetryStrategyProvider
An AutoRetryStrategyProvider that disables automatic retries;
disableAutoOnSubscribe() - Method in class io.servicetalk.concurrent.api.TestCompletable.Builder
Disable calling Subscriber#onSubscribe(Cancellable) automatically upon subscribe.
disableAutoOnSubscribe() - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Disable calling Subscriber#onSubscribe(Subscription) automatically upon subscribe.
disableAutoOnSubscribe() - Method in class io.servicetalk.concurrent.api.TestSingle.Builder
Disable calling Subscriber#onSubscribe(Cancellable) automatically upon subscribe.
disabled() - Static method in class io.servicetalk.http.netty.H2KeepAlivePolicies
Returns a H2ProtocolConfig.KeepAlivePolicy that disables all keep alive behaviors.
disableDemandCheck() - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Disables asserting items are not delivered without sufficient demand.
disableDemandCheck() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
Disables asserting items are not delivered without sufficient demand.
disableDrainingRequestPayloadBody() - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Disables automatic consumption of request payload body when it is not consumed by the service.
disableDrainingRequestPayloadBody() - Method in class io.servicetalk.http.api.HttpServerBuilder
Disables automatic consumption of request payload body when it is not consumed by the service.
disableHostHeaderFallback() - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
disableHostHeaderFallback() - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
disableHostHeaderFallback() - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
disableHostnameVerification() - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
 
disableHostnameVerification() - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
 
disableHostnameVerification() - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
 
disableHostnameVerification() - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator
Disable verification of the server identity.
disableHostnameVerification() - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig
Disable verification of the server identity.
disableLogging() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber.Builder
Disables logging signals.
disableLogging() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
Disables logging signals.
disableLogging() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber.Builder
Disables logging signals.
disableRetryAllRetryableExceptions() - Method in class io.servicetalk.client.api.DefaultAutoRetryStrategyProvider.Builder
Connection closures (by the peer or locally) and new requests may happen concurrently.
disableSpanBatching() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Disable batching of spans before sending them to the zipkin collector.
disableWaitForLoadBalancer() - Method in class io.servicetalk.client.api.DefaultAutoRetryStrategyProvider.Builder
By default, automatic retries wait for the associated LoadBalancer to be ready before triggering a retry for requests.
discardSomeReadBytes() - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Discard all Buffers which have been read.
discover(UnresolvedAddress) - Method in interface io.servicetalk.client.api.ServiceDiscoverer
Subscribe to the service discovery system for changes in the available ResolvedAddress associated with address.
dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Sets the list of the protocol families of the address resolved.
DnsResolverAddressTypes - Enum in io.servicetalk.dns.discovery.netty
Defined resolved address types.
DnsServerAddressStream - Interface in io.servicetalk.dns.discovery.netty
An infinite stream of DNS server addresses.
dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Set the DnsServerAddressStreamProvider which determines which DNS server should be used per query.
DnsServerAddressStreamProvider - Interface in io.servicetalk.dns.discovery.netty
Provides an opportunity to override which DnsServerAddressStream is used to resolve a specific hostname.
DnsServiceDiscovererObserver - Interface in io.servicetalk.dns.discovery.netty
An observer that provides visibility into DNS ServiceDiscoverer built by DefaultDnsServiceDiscovererBuilder.
DnsServiceDiscovererObserver.DnsDiscoveryObserver - Interface in io.servicetalk.dns.discovery.netty
An observer that provides visibility into individual DNS resolutions.
DnsServiceDiscovererObserver.DnsResolutionObserver - Interface in io.servicetalk.dns.discovery.netty
An observer that provides visibility into DNS resolution results.
DnsServiceDiscovererObserver.ResolutionResult - Interface in io.servicetalk.dns.discovery.netty
Results of the current DNS resolution.
doAppendHttpClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Append the filter to the chain of filters used to decorate the client created by this builder.
doAppendHttpClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
Append the filter to the chain of filters used to decorate the client created by this builder, for every request that passes the provided Predicate.
doAppendHttpServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Append the filter to the chain of filters used to decorate the service used by this builder.
doAppendHttpServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Append the filter to the chain of filters used to decorate the service used by this builder, for every request that passes the provided Predicate.
doClose(boolean) - Method in interface io.servicetalk.concurrent.api.AsyncCloseables.CloseableResource
Supplies the Completable representing the close.
doCloseAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
doCloseAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
Initiate graceful closure.
doListen(GrpcServiceFactory<?, ?, ?>) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Starts this server and returns the ServerContext after the server has been successfully started.
doListen(ConnectionAcceptor, StreamingHttpService, HttpExecutionStrategy, boolean) - Method in class io.servicetalk.http.api.HttpServerBuilder
Starts this server and returns the ServerContext after the server has been successfully started.
domain() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
domain() - Method in interface io.servicetalk.http.api.HttpSetCookie
Returns the domain of this HttpSetCookie.
domainMatches(CharSequence, CharSequence) - Static method in class io.servicetalk.http.api.HeaderUtils
domainNameMapping() - Method in class io.servicetalk.tcp.netty.internal.ReadOnlyTcpServerConfig
Gets DomainNameMapping, if any.
DomainSocketAddress - Class in io.servicetalk.transport.api
An address which represents a socket belonging to the AF_UNIX socket family.
DomainSocketAddress(String) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress
Create a new instance.
DomainSocketAddress(File) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress
Create a new instance.
duplicate() - Method in interface io.servicetalk.buffer.api.Buffer
Returns a buffer which shares the whole region of this buffer.
duplicate() - Method in interface io.servicetalk.buffer.api.BufferHolder
Duplicates this BufferHolder.
duplicate() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
duplicate() - Method in interface io.servicetalk.dns.discovery.netty.DnsServerAddressStream
Duplicate this object.
duplicate() - Method in class io.servicetalk.dns.discovery.netty.SingletonDnsServerAddresses
 
DuplicateAttributeException - Exception in io.servicetalk.client.api.partition
Indicates that a duplicate value was added while constructing a PartitionAttributes.
DuplicateAttributeException(PartitionAttributes.Key, String) - Constructor for exception io.servicetalk.client.api.partition.DuplicateAttributeException
Create a new instance.
DuplicateSubscribeException - Exception in io.servicetalk.concurrent.internal
Used in scenarios where a subscribe to an asynchronous source is subscribed to, but there is already a subscriber and the source doesn't support multiple subscribers.
DuplicateSubscribeException(Object, Object) - Constructor for exception io.servicetalk.concurrent.internal.DuplicateSubscribeException
Create a new instance.
DuplicateSubscribeException(Object, Object, String) - Constructor for exception io.servicetalk.concurrent.internal.DuplicateSubscribeException
Create a new instance.

E

EARLY_HINTS - Static variable in class io.servicetalk.http.api.HttpResponseStatus
103 Early Hints
earlyHints() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.EARLY_HINTS response.
earlyHints() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.EARLY_HINTS response.
earlyHints() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.EARLY_HINTS response.
effectiveHost() - Method in interface io.servicetalk.http.api.HttpRequestMetaData
The host component derived from HttpRequestMetaData.requestTarget() and the Host header field value.
effectivePort() - Method in interface io.servicetalk.http.api.HttpRequestMetaData
The port component derived from HttpRequestMetaData.requestTarget() and the Host header field value.
ElementsAreNonnullByDefault - Annotation Type in io.servicetalk.annotations
Indicates that fields, method parameters, method return types, and type parameters within a package are Nonnull unless explicitly annotated with Nullable.
empty() - Static method in class io.servicetalk.concurrent.api.Publisher
Creates a new Publisher that completes when subscribed without emitting any item to its PublisherSource.Subscriber.
EMPTY_BUFFER - Static variable in class io.servicetalk.buffer.api.EmptyBuffer
An instance of EmptyBuffer that can be shared.
EMPTY_SUBSCRIPTION - Static variable in class io.servicetalk.concurrent.internal.EmptySubscription
 
emptyAsciiString() - Static method in class io.servicetalk.http.api.CharSequences
Get a reference to an unmodifiable empty CharSequence with the same properties as CharSequences.newAsciiString(Buffer).
emptyAsyncCloseable() - Static method in class io.servicetalk.concurrent.api.AsyncCloseables
Creates an empty ListenableAsyncCloseable that does nothing when AsyncCloseable.closeAsync() apart from completing the ListenableAsyncCloseable.onClose().
emptyBlockingIterable() - Static method in class io.servicetalk.concurrent.internal.BlockingIterables
Get a BlockingIterable that generates BlockingIterators where Iterator.hasNext() returns true.
EmptyBuffer - Class in io.servicetalk.buffer.api
An immutable zero capacity Buffer.
EmptyHttpHeaders - Class in io.servicetalk.http.api
HttpHeaders which are always empty and does not allow modification.
emptyId() - Method in class io.servicetalk.http.router.jersey.resources.ExecutionStrategyResources.ResourceInvalidExecStrategy
 
EmptySubscription - Class in io.servicetalk.concurrent.internal
A PublisherSource.Subscription implementation, which does not do anything.
EmptySubscription() - Constructor for class io.servicetalk.concurrent.internal.EmptySubscription
 
enableDemandCheck() - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Enables asserting items are not delivered without sufficient demand.
enableDemandCheck(DemandCheckingSubscriberFunction<T>) - Method in class io.servicetalk.concurrent.api.TestPublisher.Builder
Enables asserting items are not delivered without sufficient demand, with the specified DemandCheckingSubscriberFunction.
enableDemandCheck() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
Enables asserting items are not delivered without sufficient demand.
enableFrameLogging(String) - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder
Enables a logger for HTTP/2 frames.
enableLogging() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber.Builder
Enables logging signals, with the default logger name.
enableLogging(String) - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber.Builder
Enables logging signals, with the specified logger name.
enableLogging() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
Enables logging signals, with the default logger name.
enableLogging(String) - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber.Builder
Enables logging signals, with the specified logger name.
enableLogging() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber.Builder
Enables logging signals, with the default logger name.
enableLogging(String) - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber.Builder
Enables logging signals, with the specified logger name.
enableWireLogging(String) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
enableWireLogging(String) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Enable wire-logging for this server.
enableWireLogging(String) - Method in class io.servicetalk.http.api.HttpServerBuilder
Enables wire-logging for this server.
enableWireLogging(String) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
enableWireLogging(String) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
enableWireLogging(String) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
enableWireLogging(String) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Enables wire-logging for udp packets sent.
encoded() - Method in class io.servicetalk.http.api.DefaultHttpCookiePair
 
encoded() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
encoded() - Method in interface io.servicetalk.http.api.HttpCookiePair
Get the encoded value of this HttpCookiePair.
encoding() - Method in enum io.servicetalk.grpc.api.GrpcMessageEncoding
A string representation for the message encoding.
ensureNoLeadingSlash() - Method in class io.servicetalk.http.router.jersey.CharSequenceUtilTest
 
ensureThreadAffinity(Executor) - Static method in class io.servicetalk.concurrent.api.internal.OffloaderAwareExecutor
If the passed Executor does not honor thread affinity then return a new Executor that does honor thread affinity.
ensureTrailingSlash() - Method in class io.servicetalk.http.router.jersey.CharSequenceUtilTest
 
ensureWritable(int) - Method in interface io.servicetalk.buffer.api.Buffer
Expands the buffer Buffer.capacity() to make sure the number of writable bytes is equal to or greater than the specified value.
ensureWritable(int, boolean) - Method in interface io.servicetalk.buffer.api.Buffer
Expands the buffer Buffer.capacity() to make sure the number of writable bytes is equal to or greater than the specified value.
ensureWritable(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
ensureWritable(int, boolean) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
epochMicros() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog
Get the microseconds since epoch for this InMemorySpanLog.
equals(Object) - Method in interface io.servicetalk.buffer.api.Buffer
Determines if the content of the specified buffer is identical to the content of this array.
equals(Object) - Method in class io.servicetalk.client.api.DefaultGroupKey
 
equals(Object) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key
 
equals(Object) - Method in class io.servicetalk.grpc.api.GrpcStatus
 
equals(Object) - Method in class io.servicetalk.http.api.DefaultHttpCookiePair
 
equals(Object) - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
equals(Object) - Method in class io.servicetalk.http.api.DelegatingHttpExecutionStrategy
 
equals(Object) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
equals(Object) - Method in class io.servicetalk.http.api.HttpProtocolVersion
 
equals(Object) - Method in class io.servicetalk.http.api.HttpRequestMethod
 
equals(Object) - Method in class io.servicetalk.http.api.HttpRequestMethod.Properties
 
equals(Object) - Method in class io.servicetalk.http.api.HttpResponseStatus
 
equals(Object) - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
 
equals(Object) - Method in class io.servicetalk.transport.api.DefaultExecutionContext
 
equals(Object) - Method in class io.servicetalk.transport.api.DomainSocketAddress
 
equals(Object) - Method in class io.servicetalk.transport.api.FileDescriptorSocketAddress
 
error() - Method in class io.servicetalk.concurrent.api.TestCompletableSubscriber
Get the last Throwable received by TestCompletableSubscriber.onError(Throwable).
error() - Method in class io.servicetalk.concurrent.api.TestPublisherSubscriber
Get the last Throwable received by TestPublisherSubscriber.onError(Throwable).
error() - Method in class io.servicetalk.concurrent.api.TestSingleSubscriber
Get the last Throwable received by TestSingleSubscriber.onError(Throwable).
error(Throwable) - Static method in class io.servicetalk.concurrent.internal.TerminalNotification
Returns a TerminalNotification for cause.
estimateRequestN(long) - Method in interface io.servicetalk.transport.netty.internal.WriteDemandEstimator
Given the current capacity of the write buffer, supply how many items to request next from the associated PublisherSource.Subscription.
ETAG - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"etag"
event() - Method in interface io.servicetalk.client.api.ConsumableEvent
Get the event.
event() - Method in class io.servicetalk.client.api.internal.IgnoreConsumedEvent
 
event() - Method in exception io.servicetalk.transport.netty.internal.CloseHandler.CloseEventObservedException
CloseHandler.CloseEvent was observed from the protocol or Channel.
eventConsumed() - Method in interface io.servicetalk.client.api.ConsumableEvent
Signify the ConsumableEvent.event() has been consumed and any side effects have taken place.
eventConsumed() - Method in class io.servicetalk.client.api.internal.IgnoreConsumedEvent
 
EventLoopAwareNettyIoExecutor - Interface in io.servicetalk.transport.netty.internal
A special NettyIoExecutor that exposes the underlying netty EventLoopGroup.
EventLoopAwareNettyIoExecutors - Class in io.servicetalk.transport.netty.internal
A static factory to create or convert to EventLoopAwareNettyIoExecutor.
eventLoopGroup() - Method in interface io.servicetalk.transport.netty.internal.EventLoopAwareNettyIoExecutor
Returns the underlying EventLoopGroup.
eventName() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog
Get the name of the event for this InMemorySpanLog.
eventStream() - Method in interface io.servicetalk.client.api.LoadBalancer
A Publisher of events provided by this LoadBalancer.
eventStream() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancer
 
ExceptionMapperTest - Class in io.servicetalk.http.router.jersey
 
ExceptionMapperTest(AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.ExceptionMapperTest
 
ExceptionMapperTest.TestApplication - Class in io.servicetalk.http.router.jersey
 
ExceptionMapperTest.TestExceptionMapper - Class in io.servicetalk.http.router.jersey
 
EXEC_NAME - Static variable in class io.servicetalk.http.router.jersey.resources.ExecutionStrategyResources
 
execRule - Variable in class io.servicetalk.http.router.jersey.CancellationTest
 
execute(Runnable) - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
 
execute(Runnable) - Method in class io.servicetalk.concurrent.api.internal.OffloaderAwareExecutor
 
execute(Runnable) - Method in class io.servicetalk.concurrent.api.TestExecutor
 
execute(Runnable) - Method in interface io.servicetalk.concurrent.Executor
Executes the passed task as soon as possible.
executeNextScheduledTask() - Method in class io.servicetalk.concurrent.api.TestExecutor
Execute the next scheduled (schedule/timer methods) task whose time has come.
executeNextTask() - Method in class io.servicetalk.concurrent.api.TestExecutor
Execute the next queued (execute/submit methods) task.
executeScheduledTasks() - Method in class io.servicetalk.concurrent.api.TestExecutor
Execute all scheduled (schedule/timer methods) tasks whose time has come.
executeTasks() - Method in class io.servicetalk.concurrent.api.TestExecutor
Execute all queued (execute/submit methods) tasks.
executionContext() - Method in class io.servicetalk.client.api.DefaultGroupKey
 
executionContext() - Method in interface io.servicetalk.client.api.GroupKey
Get the ExecutionContext to use when looking for or creating a new client.
executionContext() - Method in interface io.servicetalk.grpc.api.BlockingGrpcClient
Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.FilterableGrpcClient
Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.GrpcClient
Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.GrpcClientCallFactory
Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.GrpcServiceContext
 
executionContext() - Method in interface io.servicetalk.http.api.BlockingHttpRequester
Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequester
Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in class io.servicetalk.http.api.DelegatingHttpConnectionContext
 
executionContext() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
 
executionContext() - Method in interface io.servicetalk.http.api.HttpConnectionContext
 
executionContext() - Method in interface io.servicetalk.http.api.HttpRequester
Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
 
executionContext() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
 
executionContext() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
executionContext() - Method in interface io.servicetalk.http.api.StreamingHttpRequester
Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in class io.servicetalk.http.api.TestHttpServiceContext
 
executionContext() - Method in interface io.servicetalk.transport.api.ConnectionContext
executionContext() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
 
ExecutionContext - Interface in io.servicetalk.transport.api
Context related to execution and allocation.
executionContext() - Method in interface io.servicetalk.transport.api.ServerContext
Returns ExecutionContext used by this server.
executionContext() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
executionContext() - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
 
ExecutionContextBuilder - Class in io.servicetalk.transport.netty.internal
A builder of ExecutionContext.
ExecutionContextBuilder() - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
New instance.
ExecutionContextBuilder(ExecutionContextBuilder) - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Copy constructor.
ExecutionContextRule - Class in io.servicetalk.transport.netty.internal
Test helper that creates and disposes an ExecutionContext for your test case or suite.
ExecutionContextRule(Supplier<BufferAllocator>, Supplier<IoExecutor>, Supplier<Executor>) - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
ExecutionContextRule(Supplier<BufferAllocator>, Supplier<IoExecutor>, Supplier<Executor>, Supplier<ExecutionStrategy>) - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
ExecutionContextToHttpExecutionContext - Class in io.servicetalk.http.api
 
ExecutionContextToHttpExecutionContext(ExecutionContext, HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.ExecutionContextToHttpExecutionContext
 
executionStrategy(GrpcExecutionStrategy) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
 
executionStrategy() - Method in interface io.servicetalk.grpc.api.GrpcExecutionContext
Returns the GrpcExecutionStrategy associated with this context.
executionStrategy(GrpcExecutionStrategy) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder
Sets the HttpExecutionStrategy to be used by this server.
executionStrategy() - Method in class io.servicetalk.http.api.DefaultHttpExecutionContext
 
executionStrategy() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
 
executionStrategy() - Method in class io.servicetalk.http.api.ExecutionContextToHttpExecutionContext
 
executionStrategy() - Method in interface io.servicetalk.http.api.HttpExecutionContext
Returns the HttpExecutionStrategy associated with this context.
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.HttpServerBuilder
Sets the HttpExecutionStrategy to be used by this server.
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
 
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Specifies an HttpExecutionStrategy to be used for this route.
executionStrategy() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
 
executionStrategy() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
 
executionStrategy() - Method in interface io.servicetalk.transport.api.ExecutionContext
Returns the ExecutionStrategy associated with this context.
ExecutionStrategy - Interface in io.servicetalk.transport.api
An execution strategy for all transports.
executionStrategy(ExecutionStrategy) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Sets the ExecutionStrategy to use.
executionStrategy() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
ExecutionStrategyConfigurationFailuresTest - Class in io.servicetalk.http.router.jersey
 
ExecutionStrategyConfigurationFailuresTest() - Constructor for class io.servicetalk.http.router.jersey.ExecutionStrategyConfigurationFailuresTest
 
ExecutionStrategyResources - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyResources.AbstractExecutionStrategyResource - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyResources.ResourceDefaultStrategy - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyResources.ResourceInvalidExecStrategy - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyResources.ResourceRouteExecIdStrategy - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyResources.ResourceRouteNoOffloadsStrategy - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyResources.ResourceUnsupportedAsync - Class in io.servicetalk.http.router.jersey.resources
 
ExecutionStrategyTest - Class in io.servicetalk.http.router.jersey
 
ExecutionStrategyTest(ExecutionStrategyTest.TestExecutorStrategy, ExecutionStrategyTest.TestExecutorStrategy, ExecutionStrategyTest.TestExecutorStrategy, ExecutionStrategyTest.TestMode, String, AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi) - Constructor for class io.servicetalk.http.router.jersey.ExecutionStrategyTest
 
ExecutionStrategyTest.TestApplication - Class in io.servicetalk.http.router.jersey
 
ExecutionStrategyTest.TestExecutorStrategy - Enum in io.servicetalk.http.router.jersey
 
ExecutionStrategyTest.TestMode - Enum in io.servicetalk.http.router.jersey
 
Executor - Interface in io.servicetalk.concurrent.api
A general abstraction to execute immediate and delayed tasks.
executor() - Method in class io.servicetalk.concurrent.api.ExecutorRule
Returns Executor created on the last call to ExecutorRule.before().
Executor - Interface in io.servicetalk.concurrent
A general abstraction to execute immediate and delayed tasks.
executor(Executor) - Method in class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder
Specify an Executor to use.
executor() - Method in class io.servicetalk.http.api.DefaultHttpExecutionContext
 
executor() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
 
executor() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionStrategy
 
executor() - Method in class io.servicetalk.http.api.ExecutionContextToHttpExecutionContext
 
executor(Executor) - Method in class io.servicetalk.http.api.HttpExecutionStrategies.Builder
Specify an Executor to use.
executor(Executor) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Sets an Executor to use when required.
executor() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
 
executor() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
 
executor() - Method in interface io.servicetalk.transport.api.ExecutionContext
Get the Executor that is used to create any asynchronous sources.
executor() - Method in interface io.servicetalk.transport.api.ExecutionStrategy
Returns the Executor, if any for this ExecutionStrategy.
executor(Executor) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Sets the Executor to use.
executor() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
ExecutorRule<E extends Executor> - Class in io.servicetalk.concurrent.api
An ExternalResource wrapper for an Executor.
Executors - Class in io.servicetalk.concurrent.api
Utility methods to create various Executors.
EXPECT - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"expect"
EXPECTATION_FAILED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
417 Expectation Failed
expectationFailed() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
expectationFailed() - Method in interface io.servicetalk.http.api.HttpResponseFactory
expectationFailed() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
expected - Variable in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
expected - Variable in class io.servicetalk.http.router.jersey.ExecutionStrategyConfigurationFailuresTest
 
expectThrowable(Runnable, Class<? extends Throwable>) - Static method in class io.servicetalk.concurrent.api.VerificationTestUtils
 
expectThrowable(Runnable, Matcher<Throwable>) - Static method in class io.servicetalk.concurrent.api.VerificationTestUtils
 
expires() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
EXPIRES - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"expires"
expires() - Method in interface io.servicetalk.http.api.HttpSetCookie
Returns the expire date of this HttpSetCookie according to Expires.
explicitHead() - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest
 
explicitHead() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
explicitHead(String) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
explicitHead(String) - Method in class io.servicetalk.http.router.jersey.resources.SynchronousResources
 
extract(Format<C>, C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
 
extract(C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTraceStateFormat
Extract the trace state from a carrier.
extract(SingleLineValue) - Method in class io.servicetalk.opentracing.inmemory.SingleLineFormatter
 
extractByteBufOrCreate(Buffer) - Static method in class io.servicetalk.buffer.netty.BufferUtils
Converts the passed buffer to ByteBuf, creating a new ByteBuf instance if required.
extractSslSession(ChannelPipeline, SslHandshakeCompletionEvent, Consumer<Throwable>) - Static method in class io.servicetalk.transport.netty.internal.NettyPipelineSslUtils
Extract the SSLSession from the ChannelPipeline if the SslHandshakeCompletionEvent is successful.

F

fail(Throwable) - Method in interface io.servicetalk.concurrent.BlockingIterable.Processor
Terminates this BlockingIterable and all the current or future BlockingIterators with a failure.
failed(Throwable) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a realized failed Completable.
failed(Throwable) - Static method in class io.servicetalk.concurrent.api.Publisher
Creates a new Publisher that terminates its PublisherSource.Subscriber with an error without emitting any item to it.
failed(Throwable) - Static method in class io.servicetalk.concurrent.api.Single
Creates a realized Single which always completes with the provided error cause.
FAILED_DEPENDENCY - Static variable in class io.servicetalk.http.api.HttpResponseStatus
424 Failed Dependency
failedDependency() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
failedDependency() - Method in interface io.servicetalk.http.api.HttpResponseFactory
failedDependency() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
failedText() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
fields() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog
Get the fields associated with this InMemorySpanLog.
FileDescriptorSocketAddress - Class in io.servicetalk.transport.api
Special SocketAddress that allows to wrap an already existing filedescriptor.
FileDescriptorSocketAddress(int) - Constructor for class io.servicetalk.transport.api.FileDescriptorSocketAddress
Constructs a new instance which wraps an existing filedescriptor.
fillInStackTrace() - Method in exception io.servicetalk.concurrent.internal.DeliberateException
 
fillInStackTrace() - Method in exception io.servicetalk.transport.netty.internal.CloseHandler.CloseEventObservedException
 
fillInStackTrace() - Method in exception io.servicetalk.transport.netty.internal.StacklessClosedChannelException
 
filter(Predicate<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher
Filters items emitted by this Publisher.
filter(ContainerRequestContext) - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest.TestGlobalFilter
 
filter(ContainerRequestContext, ContainerResponseContext) - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest.TestGlobalFilter
 
filter(ContainerRequestContext) - Method in class io.servicetalk.http.router.jersey.AbstractFilterInterceptorTest.TestInputConsumingGlobalFilter
 
filter(ContainerRequestContext) - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest.TestFilter
 
filter(ContainerRequestContext, ContainerResponseContext) - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest.TestFilter
 
filter(ContainerRequestContext) - Method in class io.servicetalk.http.router.jersey.IllBehavedRequestFilterTest.IllBehavedRequestFilter
 
filter(ContainerRequestContext) - Method in class io.servicetalk.http.router.jersey.SecurityFilterTest.TestSecurityFilter
 
FilterableGrpcClient - Interface in io.servicetalk.grpc.api
A client to a gRPC service that supports filtering.
FilterableReservedStreamingHttpConnection - Interface in io.servicetalk.http.api
FilterableStreamingHttpClient - Interface in io.servicetalk.http.api
A StreamingHttpClient that supports filtering.
FilterableStreamingHttpConnection - Interface in io.servicetalk.http.api
A StreamingHttpConnection that supported filtering.
FilterableStreamingHttpLoadBalancedConnection - Interface in io.servicetalk.http.api
A FilterableStreamingHttpConnection that supported filtering and implements the LoadBalancedConnection contract.
filtered() - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest
 
filtered(String) - Method in class io.servicetalk.http.router.jersey.resources.SynchronousResources
 
findNextPositivePowerOfTwo(int) - Static method in class io.servicetalk.utils.internal.MathUtils
Fast method of finding the next power of 2 greater than or equal to the supplied value.
finish() - Method in interface io.servicetalk.concurrent.api.BufferStrategy.Accumulator
Finishes accumulation and returns the accumulated value.
firstOrElse(Supplier<T>) - Method in class io.servicetalk.concurrent.api.Publisher
Converts this Publisher to a Single.
firstOrError() - Method in class io.servicetalk.concurrent.api.Publisher
Ensures that this Publisher emits exactly a single PublisherSource.Subscriber.onNext(Object) to its PublisherSource.Subscriber.
firstValue(CharSequence) - Method in interface io.servicetalk.http.router.predicate.dsl.StringMultiValueMatcher
Matches requests where the first value in the request is equal to value.
firstValue(Predicate<CharSequence>) - Method in interface io.servicetalk.http.router.predicate.dsl.StringMultiValueMatcher
Matches requests where the first value in the request matches predicate.
firstValueMatches(String) - Method in interface io.servicetalk.http.router.predicate.dsl.StringMultiValueMatcher
Matches requests where the first value in the request matches the regex regex.
firstValueMatches(Pattern) - Method in interface io.servicetalk.http.router.predicate.dsl.StringMultiValueMatcher
Matches requests where the first value in the request matches the regex regex.
fixed(int) - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
fixed(int, ThreadFactory) - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextRule
 
flatMap(Function<? super T, ? extends Single<? extends R>>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Single that mirrors emissions from the Single returned by next.
flatMapCompletable(Function<? super T, ? extends Completable>) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Completable and terminate the returned Completable when all the intermediate Completables have terminated successfully or any one of them has terminated with a failure.
flatMapCompletable(Function<? super T, ? extends Completable>, int) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Completable and terminate the returned Completable when all the intermediate Completables have terminated successfully or any one of them has terminated with a failure.
flatMapCompletable(Function<? super T, ? extends Completable>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Completable that mirrors emissions from the Completable returned by next.
flatMapCompletableDelayError(Function<? super T, ? extends Completable>) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Completable and terminate the returned Completable when all the intermediate Completables have terminated.
flatMapCompletableDelayError(Function<? super T, ? extends Completable>, int) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Completable and terminate the returned Completable when all the intermediate Completables have terminated.If any Completable returned by mapper, terminates with an error, the returned Completable will not immediately terminate.
flatMapConcatIterable(Function<? super T, ? extends Iterable<? extends R>>) - Method in class io.servicetalk.concurrent.api.Publisher
Create a Publisher that flattens each element returned by the Iterable.iterator() from mapper.
flatMapMergeSingle(Function<? super T, ? extends Single<? extends R>>) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Single and emits the items emitted by each of those Singles.
flatMapMergeSingle(Function<? super T, ? extends Single<? extends R>>, int) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Single and emits the items emitted by each of those Singles.
flatMapMergeSingleDelayError(Function<? super T, ? extends Single<? extends R>>) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Single and emits the items emitted by each of those Singles.
flatMapMergeSingleDelayError(Function<? super T, ? extends Single<? extends R>>, int) - Method in class io.servicetalk.concurrent.api.Publisher
Turns every item emitted by this Publisher into a Single and emits the items emitted by each of those Singles.
flatMapPublisher(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Publisher that mirrors emissions from the Publisher returned by next.
FlowControlUtils - Class in io.servicetalk.concurrent.internal
A set of utility methods for safe math operations to prevent overflow.
flush() - Method in class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
 
flush() - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
 
flush() - Method in interface io.servicetalk.transport.netty.internal.FlushStrategy.FlushSender
Sends a flush on the associated connection.
flushOnEach() - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
flushOnEnd() - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
FlushStrategies - Class in io.servicetalk.transport.netty.internal
A factory for creating FlushStrategy.
FlushStrategy - Interface in io.servicetalk.transport.netty.internal
A strategy that defines how to flush writes on a connection.
FlushStrategy.FlushSender - Interface in io.servicetalk.transport.netty.internal
An abstraction for a FlushStrategy to flush writes by calling FlushStrategy.FlushSender.flush().
FlushStrategy.WriteEventsListener - Interface in io.servicetalk.transport.netty.internal
A listener of write events from the connection on which the related FlushStrategy is applied.
FlushStrategyHolder - Class in io.servicetalk.transport.netty.internal
A utility class to hold a FlushStrategy and allow it to be updated atomically using FlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider).
FlushStrategyHolder(FlushStrategy) - Constructor for class io.servicetalk.transport.netty.internal.FlushStrategyHolder
Creates new instance.
flushWith(Publisher<?>) - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
Creates a FlushStrategy that will flush writes when an item is emitted from flushBoundaries.
forAddress(String, int) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forAddress(HostAndPort) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forAddress(ServiceDiscoverer<U, R, ? extends ServiceDiscovererEvent<R>>, U) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for a custom address type with default LoadBalancer and user provided ServiceDiscoverer.
forAddress(SocketAddress) - Static method in class io.servicetalk.grpc.netty.GrpcServers
New GrpcServerBuilder instance.
forAddress(SocketAddress) - Static method in class io.servicetalk.http.netty.HttpServers
New HttpServerBuilder instance.
forbidden() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.FORBIDDEN response.
forbidden() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.FORBIDDEN response.
FORBIDDEN - Static variable in class io.servicetalk.http.api.HttpResponseStatus
403 Forbidden
forbidden() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.FORBIDDEN response.
forClient(ReadOnlyClientSecurityConfig, List<String>) - Static method in class io.servicetalk.transport.netty.internal.SslContextFactory
A new context for a client using the passed config.
forCountOrTime(int, Duration) - Static method in class io.servicetalk.concurrent.api.BufferStrategies
Returns a BufferStrategy that creates buffer boundaries based on number of items buffered or time elapsed since the current buffer boundary started.
forCountOrTime(int, Duration, Executor) - Static method in class io.servicetalk.concurrent.api.BufferStrategies
Returns a BufferStrategy that creates buffer boundaries based on number of items buffered or time elapsed since the current buffer boundary started.
forCountOrTime(int, Duration, Supplier<BC>) - Static method in class io.servicetalk.concurrent.api.BufferStrategies
Returns a BufferStrategy that creates buffer boundaries based on number of items buffered or time elapsed since the current buffer boundary started.
forCountOrTime(int, Duration, Supplier<BC>, Executor) - Static method in class io.servicetalk.concurrent.api.BufferStrategies
Returns a BufferStrategy that creates buffer boundaries based on number of items buffered or time elapsed since the current buffer boundary started.
forEach(BiConsumer<PartitionAttributes.Key, Object>) - Method in interface io.servicetalk.client.api.partition.PartitionAttributes
Iterate over the key/value pairs in this collection.
forEach(BiPredicate<AsyncContextMap.Key<?>, Object>) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to iterate over the key/value pairs contained in the current context.
forEach(BiPredicate<AsyncContextMap.Key<?>, Object>) - Method in interface io.servicetalk.concurrent.api.AsyncContextMap
Iterate over the key/value pairs contained in this request context.
forEach(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher
Subscribes to this Publisher and invokes forEach Consumer for each item emitted by this Publisher.
forEach(Consumer<? super T>, LongSupplier, TimeUnit) - Method in interface io.servicetalk.concurrent.BlockingIterable
Mimics the behavior of Iterable.forEach(Consumer) but uses the timeoutSupplier to determine the timeout value for interactions with the BlockingIterator.
forEach(Consumer<? super T>, long, TimeUnit) - Method in interface io.servicetalk.concurrent.BlockingIterable
Mimics the behavior of Iterable.forEach(Consumer) but applies a timeout duration for the overall completion of this method.
forEachByte(ByteProcessor) - Method in interface io.servicetalk.buffer.api.Buffer
Iterates over the readable bytes of this buffer with the specified processor in ascending order.
forEachByte(int, int, ByteProcessor) - Method in interface io.servicetalk.buffer.api.Buffer
Iterates over the specified area of this buffer with the specified processor in ascending order.
forEachByte(ByteProcessor) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
forEachByte(int, int, ByteProcessor) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
forEachByteDesc(ByteProcessor) - Method in interface io.servicetalk.buffer.api.Buffer
Iterates over the readable bytes of this buffer with the specified processor in descending order.
forEachByteDesc(int, int, ByteProcessor) - Method in interface io.servicetalk.buffer.api.Buffer
Iterates over the specified area of this buffer with the specified processor in descending order.
forEachByteDesc(ByteProcessor) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
forEachByteDesc(int, int, ByteProcessor) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
forGlobalBinding(AsyncContextMap.Key<UserInfo>) - Static method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters
Creates a new BasicAuthSecurityContextFilters.UserInfoBuilder instance for building a ContainerRequestFilter that needs to be globally bound to the JAX-RS Application.
forGlobalBinding() - Static method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters
Creates a new BasicAuthSecurityContextFilters.NoUserInfoBuilder instance for building a ContainerRequestFilter that needs to be globally bound to the JAX-RS Application.
format(long, long, Long) - Static method in interface io.servicetalk.opentracing.inmemory.SingleLineValue
Formats the provided trace information.
format(String, String, String) - Static method in interface io.servicetalk.opentracing.inmemory.SingleLineValue
Formats the provided trace information.
format(String, String, String, boolean) - Static method in interface io.servicetalk.opentracing.inmemory.SingleLineValue
Formats the provided trace information.
formatCanonicalAddress(SocketAddress) - Static method in class io.servicetalk.transport.netty.internal.BuilderUtils
Format an address into a canonical numeric format.
forMultiAddressUrl() - Static method in class io.servicetalk.http.netty.HttpClients
Creates a MultiAddressHttpClientBuilder for clients capable of parsing an absolute-form URL, connecting to multiple addresses with default LoadBalancer and DNS ServiceDiscoverer.
forMultiAddressUrl(ServiceDiscoverer<HostAndPort, InetSocketAddress, ? extends ServiceDiscovererEvent<InetSocketAddress>>) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a MultiAddressHttpClientBuilder for clients capable of parsing an absolute-form URL, connecting to multiple addresses with default LoadBalancer and user provided ServiceDiscoverer.
formUrlEncodedDeserializer() - Static method in class io.servicetalk.http.api.HttpSerializationProviders
Creates an HttpDeserializer that can deserialize key-values Maps with StandardCharsets.UTF_8 from urlencoded forms.
formUrlEncodedDeserializer(Charset) - Static method in class io.servicetalk.http.api.HttpSerializationProviders
Creates an HttpDeserializer that can deserialize key-values Maps with StandardCharsets.UTF_8 from urlencoded forms.
formUrlEncodedDeserializer(Charset, Predicate<HttpHeaders>) - Static method in class io.servicetalk.http.api.HttpSerializationProviders
Creates an HttpDeserializer that can deserialize key-values Maps with StandardCharsets.UTF_8 from urlencoded forms.
formUrlEncodedSerializer() - Static method in class io.servicetalk.http.api.HttpSerializationProviders
Creates an HttpSerializer that can serialize a key-values Maps with StandardCharsets.UTF_8 Charset to urlencoded forms.
formUrlEncodedSerializer(Charset) - Static method in class io.servicetalk.http.api.HttpSerializationProviders
Creates an HttpSerializer that can serialize key-values Maps with the specified Charset to to urlencoded forms.
formUrlEncodedSerializer(Charset, Consumer<HttpHeaders>) - Static method in class io.servicetalk.http.api.HttpSerializationProviders
Creates an HttpSerializer that can serialize a key-values Maps with the specified Charset to urlencoded forms.
forNameBinding(AsyncContextMap.Key<UserInfo>) - Static method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters
Creates a new BasicAuthSecurityContextFilters.UserInfoBuilder instance for building a ContainerRequestFilter that needs to be explicitly bound to resources via the BasicAuthenticated annotation.
forNameBinding() - Static method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters
Creates a new BasicAuthSecurityContextFilters.NoUserInfoBuilder instance for building a ContainerRequestFilter that needs to be explicitly bound to resources via the BasicAuthenticated annotation.
forPartitionedAddress(ServiceDiscoverer<U, R, ? extends PartitionedServiceDiscovererEvent<R>>, U, Function<HttpRequestMetaData, PartitionAttributesBuilder>) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a PartitionedHttpClientBuilder for a custom address type with default LoadBalancer and user provided ServiceDiscoverer.
forPipelinedRequestResponse(boolean, ChannelConfig) - Static method in class io.servicetalk.transport.netty.internal.CloseHandler
New CloseHandler instance.
forPort(int) - Static method in class io.servicetalk.grpc.netty.GrpcServers
New GrpcServerBuilder instance.
forPort(int) - Static method in class io.servicetalk.http.netty.HttpServers
New HttpServerBuilder instance.
forResolvedAddress(String, int) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for a resolved address with default LoadBalancer.
forResolvedAddress(HostAndPort) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forResolvedAddress(InetSocketAddress) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forResolvedAddress(String, int) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for a resolved address with default LoadBalancer.
forResolvedAddress(HostAndPort) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forResolvedAddress(InetSocketAddress) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forResolvedAddressViaProxy(String, int, String, int) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for a resolved address via a proxy, with default LoadBalancer.
forResolvedAddressViaProxy(HostAndPort, HostAndPort) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address via a proxy, with default LoadBalancer and DNS ServiceDiscoverer.
forResolvedAddressViaProxy(InetSocketAddress, InetSocketAddress) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address via a proxy, with default LoadBalancer and DNS ServiceDiscoverer.
forServer(ReadOnlyServerSecurityConfig, List<String>) - Static method in class io.servicetalk.transport.netty.internal.SslContextFactory
A new context for a server using the passed config.
forServiceAddress(String) - Static method in class io.servicetalk.grpc.netty.GrpcClients
Creates a GrpcClientBuilder for the passed serviceName with default LoadBalancer and a DNS ServiceDiscoverer using SRV record lookups.
forServiceAddress(String) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for the passed serviceName with default LoadBalancer and a DNS ServiceDiscoverer using SRV record lookups.
forSingleAddress(String, int) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forSingleAddress(HostAndPort) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address with default LoadBalancer and DNS ServiceDiscoverer.
forSingleAddress(ServiceDiscoverer<U, R, ? extends ServiceDiscovererEvent<R>>, U) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for a custom address type with default LoadBalancer and user provided ServiceDiscoverer.
forSingleAddressViaProxy(String, int, String, int) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address via a proxy, with default LoadBalancer and DNS ServiceDiscoverer.
forSingleAddressViaProxy(HostAndPort, HostAndPort) - Static method in class io.servicetalk.http.netty.HttpClients
Creates a SingleAddressHttpClientBuilder for an address via a proxy, with default LoadBalancer and DNS ServiceDiscoverer.
FORWARDED - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"forwarded" is a header field that contains a list of parameter-identifier pairs that disclose information that is altered or lost when a proxy is involved in the path of the request.
found() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.FOUND response.
found() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.FOUND response.
FOUND - Static variable in class io.servicetalk.http.api.HttpResponseStatus
302 Found
found() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.FOUND response.
frameLoggerName() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig
Logger name for HTTP/2 frames.
freeMemory(long) - Static method in class io.servicetalk.utils.internal.PlatformDependent
Deallocates direct memory.
from(Function<Key, Client>) - Static method in interface io.servicetalk.client.api.ClientGroup
Creates a ClientGroup based on a factory of clients of type Client.
from(Executor) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor from the provided jdkExecutor.
from(ExecutorService) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor from the provided ExecutorService.
from(ExecutorService, boolean) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor from the provided ExecutorService.
from(ScheduledExecutorService) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor from the provided ScheduledExecutorService.
from(ScheduledExecutorService, boolean) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor from the provided ScheduledExecutorService.
from(Executor, ScheduledExecutorService) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor using executor to execute immediate tasks and scheduler to schedule delayed tasks.
from(Executor, ScheduledExecutorService, boolean) - Static method in class io.servicetalk.concurrent.api.Executors
Creates a new Executor using executor to execute immediate tasks and scheduler to schedule delayed tasks.
from(T) - Static method in class io.servicetalk.concurrent.api.Publisher
Creates a new Publisher that emits value to its PublisherSource.Subscriber and then PublisherSource.Subscriber.onComplete().
from(T...) - Static method in class io.servicetalk.concurrent.api.Publisher
Creates a new Publisher that emits all values to its PublisherSource.Subscriber and then PublisherSource.Subscriber.onComplete().
from(Runnable) - Static method in interface io.servicetalk.concurrent.api.SingleTerminalSignalConsumer
Create a SingleTerminalSignalConsumer where each method executes a Runnable.run().
from(Runnable) - Static method in interface io.servicetalk.concurrent.api.TerminalSignalConsumer
Create a TerminalSignalConsumer where each method executes a Runnable.run().
from(Iterable<T>) - Static method in class io.servicetalk.concurrent.internal.BlockingIterables
Convert from a Iterable to a BlockingIterable.
from(CloseableIterable<T>) - Static method in class io.servicetalk.concurrent.internal.BlockingIterables
Convert from a Iterable to a CloseableIterable.
from(StreamingHttpClient) - Static method in interface io.servicetalk.grpc.api.GrpcClientCallFactory
Creates a new GrpcClientCallFactory using the passed StreamingHttpClient.
from(HttpExecutionStrategy) - Static method in interface io.servicetalk.grpc.api.GrpcExecutionStrategy
Creates a new GrpcExecutionStrategy from the passed HttpExecutionStrategy.
from(FF) - Static method in interface io.servicetalk.http.api.ConditionalFilterFactory.FilterFactory
 
FROM - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"from"
from(BiFunction<U, FilterableStreamingHttpClient, StreamingHttpClientFilter>) - Static method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory
Returns a function that adapts from the UnaryOperator<FilterableStreamingHttpClient> function type to the MultiAddressHttpClientFilterFactory.
from(Function<FilterableStreamingHttpClient, StreamingHttpClientFilter>) - Static method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory
Returns a function that adapts from a Function<FilterableStreamingHttpClient, StreamingHttpClientFilter> to the StreamingHttpClientFilterFactory.
from(StreamingHttpRequestResponseFactory, HttpExecutionContext, StreamingHttpClientFilterFactory) - Static method in class io.servicetalk.http.api.TestStreamingHttpClient
 
from(FilterableStreamingHttpClient) - Static method in class io.servicetalk.http.api.TestStreamingHttpClient
 
from(StreamingHttpRequestResponseFactory, HttpExecutionContext, HttpConnectionContext, StreamingHttpConnectionFilterFactory) - Static method in class io.servicetalk.http.api.TestStreamingHttpConnection
 
from(FilterableStreamingHttpConnection) - Static method in class io.servicetalk.http.api.TestStreamingHttpConnection
 
from(LoadBalancerFactory<ResolvedAddress, FilterableStreamingHttpLoadBalancedConnection>) - Static method in class io.servicetalk.http.netty.DefaultHttpLoadBalancerFactory.Builder
fromAscii(CharSequence) - Method in interface io.servicetalk.buffer.api.BufferAllocator
Create a new Buffer from the given CharSequence using Ascii encoding.
fromAscii(CharSequence, boolean) - Method in interface io.servicetalk.buffer.api.BufferAllocator
Create a new Buffer from the given CharSequence using Ascii encoding.
fromBlockingIterable(BlockingIterable<? extends T>, LongSupplier, TimeUnit) - Static method in class io.servicetalk.concurrent.api.Publisher
Create a new Publisher that when subscribed will get a BlockingIterator via BlockingIterable.iterator() and emit all values to the PublisherSource.Subscriber and then PublisherSource.Subscriber.onComplete().
fromCallable(Callable<T>) - Static method in class io.servicetalk.concurrent.api.Single
Creates a Single which when subscribed will invoke Callable.call() on the passed Callable and emit the value returned by that invocation from the returned Single.
fromCodeValue(String) - Static method in class io.servicetalk.grpc.api.GrpcStatus
Obtains the status given a code value string.
fromCodeValue(int) - Static method in class io.servicetalk.grpc.api.GrpcStatus
Obtains the status given an integer code value.
fromCodeValue(CharSequence) - Static method in enum io.servicetalk.grpc.api.GrpcStatusCode
Obtains the status code given a code value.
fromCodeValue(int) - Static method in enum io.servicetalk.grpc.api.GrpcStatusCode
Obtains the status code given an integer code value.
fromDefaults() - Static method in class io.servicetalk.http.netty.DefaultHttpLoadBalancerFactory.Builder
Creates a new DefaultHttpLoadBalancerFactory.Builder instance using the default LoadBalancer implementation.
fromFuture(Future<?>) - Static method in class io.servicetalk.concurrent.api.Completable
Convert from a Future to a Completable via Future.get().
fromFuture(Future<? extends T>) - Static method in class io.servicetalk.concurrent.api.Single
Convert from a Future to a Single via Future.get().
fromInputStream(InputStream) - Static method in class io.servicetalk.concurrent.api.Publisher
Create a new Publisher that when subscribed will emit all data from the InputStream to the PublisherSource.Subscriber and then PublisherSource.Subscriber.onComplete().
fromIterable(Iterable<? extends T>) - Static method in class io.servicetalk.concurrent.api.Publisher
Create a new Publisher that when subscribed will get an Iterator via Iterable.iterator() and emit all values to the PublisherSource.Subscriber and then PublisherSource.Subscriber.onComplete().
fromNettyEventLoop(EventLoop) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Creates a new instance of NettyIoExecutor using the passed EventLoop.
fromNettyEventLoopGroup(EventLoopGroup) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Creates a new instance of NettyIoExecutor using the passed EventLoopGroup.
fromReactiveStreamsPublisher(Publisher<T>) - Static method in class io.servicetalk.concurrent.reactivestreams.ReactiveStreamsAdapters
Converts the passed Publisher to a Reactive Streams Publisher.
fromRunnable(Runnable) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a Completable which when subscribed will invoke Runnable.run() on the passed Runnable and emit the value returned by that invocation from the returned Completable.
fromSequence(CharSequence, Charset) - Method in interface io.servicetalk.buffer.api.BufferAllocator
Create a new Buffer from the given CharSequence using the Charset.
fromSequence(CharSequence, Charset, boolean) - Method in interface io.servicetalk.buffer.api.BufferAllocator
Create a new Buffer from the given CharSequence using the Charset.
fromSource(PublisherSource<T>) - Static method in class io.servicetalk.concurrent.api.SourceAdapters
Converts the provided PublisherSource into a Publisher.
fromSource(SingleSource<T>) - Static method in class io.servicetalk.concurrent.api.SourceAdapters
Converts the provided SingleSource into a Single.
fromSource(CompletableSource) - Static method in class io.servicetalk.concurrent.api.SourceAdapters
Converts the provided CompletableSource into a Completable.
fromStage(CompletionStage<?>) - Static method in class io.servicetalk.concurrent.api.Completable
Convert from a CompletionStage to a Completable.
fromStage(CompletionStage<? extends T>) - Static method in class io.servicetalk.concurrent.api.Single
Convert from a CompletionStage to a Single.
fromStatusCode(int) - Static method in enum io.servicetalk.http.api.HttpResponseStatus.StatusClass
Determines the HttpResponseStatus.StatusClass from the statusCode.
fromSupplier(Supplier<T>) - Static method in class io.servicetalk.concurrent.api.Single
Creates a Single which when subscribed will invoke Supplier.get() on the passed Supplier and emit the value returned by that invocation from the returned Single.
fromThrowable(Throwable) - Static method in class io.servicetalk.grpc.api.GrpcStatus
Translates a throwable into a status.
fromThrowableNullable(Throwable) - Static method in class io.servicetalk.grpc.api.GrpcStatus
Translates a throwable into a status.
fromUtf8(CharSequence) - Method in interface io.servicetalk.buffer.api.BufferAllocator
Create a new Buffer from the given CharSequence using UTF-8 encoding.
fromUtf8(CharSequence, boolean) - Method in interface io.servicetalk.buffer.api.BufferAllocator
Create a new Buffer from the given CharSequence using UTF-8 encoding.
FutureUtils - Class in io.servicetalk.concurrent.internal
A set of utilities for interacting with Future.

G

GATEWAY_TIMEOUT - Static variable in class io.servicetalk.http.api.HttpResponseStatus
504 Gateway Timeout
gatewayTimeout() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.GATEWAY_TIMEOUT response.
gatewayTimeout() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.GATEWAY_TIMEOUT response.
gatewayTimeout() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.GATEWAY_TIMEOUT response.
get(Key) - Method in interface io.servicetalk.client.api.ClientGroup
Return the Client identified by the provided key or create a new one when none exists.
get(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
 
get(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
 
get(PartitionAttributes.Key<T>) - Method in interface io.servicetalk.client.api.partition.PartitionAttributes
Get the value associated with key.
get(PartitionAttributes) - Method in interface io.servicetalk.client.api.partition.PartitionMap
Get the partition value corresponding to the PartitionAttributes parameter.
get(AsyncContextMap.Key<T>) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to get the value associated with key from the current context.
get(AsyncContextMap.Key<T>) - Method in interface io.servicetalk.concurrent.api.AsyncContextMap
Get the value associated with key, or null if no value is associated.
get(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory
Create a new HttpRequestMethod.GET request.
get(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
get(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
get(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns the value of a header with the specified name.
get(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns the value of a header with the specified name.
get(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory
Create a new HttpRequestMethod.GET request.
GET - Static variable in class io.servicetalk.http.api.HttpRequestMethod
HTTP GET method.
get(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory
Create a new HttpRequestMethod.GET request.
get(String) - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
get(String) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
get() - Method in interface io.servicetalk.opentracing.inmemory.SingleLineValue
Gets the value.
get(String) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
get(String) - Method in interface io.servicetalk.router.api.RouteExecutionStrategyFactory
Gets an execution strategy for the specified idid of RouteExecutionStrategy annotation.
get(String) - Method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory
 
get444Status() - Method in class io.servicetalk.http.router.jersey.resources.SynchronousResources
 
getAndRemove(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
getAndRemove(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns the value of a header with the specified name and removes it from this object.
getAndRemove(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns the value of a header with the specified name and removes it from this object.
getAndValidateRouteExecutionStrategyAnnotationIfPresent(Method, Class<?>, RouteExecutionStrategyFactory<T>, Set<String>, T) - Static method in class io.servicetalk.router.utils.internal.RouteExecutionStrategyUtils
Returns ExecutionStrategy for the specified Method and validates that configuration of RouteExecutionStrategy annotation is correct if present.
getAnInt() - Method in class io.servicetalk.http.router.jersey.TestPojo
 
getaString() - Method in class io.servicetalk.http.router.jersey.TestPojo
 
getAsyncResponseBusy(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAsyncResponseCancel(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAsyncResponseResume(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAsyncResponseResumeTimeout(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAsyncResponseTimeoutExpire(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAsyncResponseTimeoutExpireHandled(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAsyncResponseTimeoutResume(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getAuthenticationScheme() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
 
getBaseRequestUri(ConnectionContext, HttpRequestMetaData, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils
Get the base URI for the provided ConnectionContext and HttpRequestMetaData.
getBaseRequestUri(ConnectionContext, HttpRequestMetaData, String, String, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils
Get the base URI for the provided ConnectionContext and HttpRequestMetaData.
getBoolean(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a boolean at the specified absolute (@code index) in this buffer.
getBoolean(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getByte(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a byte at the specified absolute index in this buffer.
getByte(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getByteBufAllocator(BufferAllocator) - Static method in class io.servicetalk.buffer.netty.BufferUtils
Returns the ByteBufAllocator taking the BufferAllocator into account.
getBytes(int, Buffer) - Method in interface io.servicetalk.buffer.api.Buffer
Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination becomes non-writable.
getBytes(int, Buffer, int) - Method in interface io.servicetalk.buffer.api.Buffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, Buffer, int, int) - Method in interface io.servicetalk.buffer.api.Buffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, byte[]) - Method in interface io.servicetalk.buffer.api.Buffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, byte[], int, int) - Method in interface io.servicetalk.buffer.api.Buffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, ByteBuffer) - Method in interface io.servicetalk.buffer.api.Buffer
Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit.
getBytes(int, Buffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
getBytes(int, Buffer, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
getBytes(int, Buffer, int, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
getBytes(int, byte[]) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
getBytes(int, byte[], int, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
getBytes(int, ByteBuffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
getBytes(int, Buffer) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getBytes(int, Buffer, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getBytes(int, Buffer, int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getBytes(int, byte[]) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getBytes(int, byte[], int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getBytes(int, ByteBuffer) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getChar(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 2-byte UTF-16 character at the specified absolute index in this buffer.
getChar(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getClasses() - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.ExceptionMapperTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.ExecutionStrategyTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.GlobalFiltersTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.IllBehavedRequestFilterTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.InputConsumingGlobalFiltersTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.InterceptorsTest.TestApplication
 
getClasses() - Method in class io.servicetalk.http.router.jersey.SecurityFilterTest.TestApplication
 
getCompletable() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getCompletableOut(boolean) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getCompletionStageString(ConnectionContext) - Method in class io.servicetalk.http.router.jersey.resources.MixedModeResources
 
getContentAsString(StreamingHttpResponse) - Static method in class io.servicetalk.http.router.jersey.TestUtils
 
getContentAsString(Publisher<Buffer>) - Static method in class io.servicetalk.http.router.jersey.TestUtils
 
getCookie(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
getCookie(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Gets a cookie identified by name.
getCookies() - Method in interface io.servicetalk.http.api.HttpHeaders
Gets all the cookies.
getCookies(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Gets the cookies with the same name.
getCookiesIterator() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
getCookiesIterator(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
getCookiesIterator() - Method in interface io.servicetalk.http.api.HttpHeaders
Gets all the cookies.
getCookiesIterator(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Gets the cookies with the same name.
getCopy() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
getCopy() - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
getCopyOrNull() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
getCopyOrNull() - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
getDelayedResponseCompletionStage(long, TimeUnit) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getDelayedText() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getDelayedText(long, TimeUnit) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getDeserializer(Class<T>) - Method in class io.servicetalk.data.jackson.JacksonSerializationProvider
 
getDeserializer(TypeHolder<T>) - Method in class io.servicetalk.data.jackson.JacksonSerializationProvider
 
getDeserializer(Class<T>) - Method in class io.servicetalk.data.protobuf.ProtobufSerializationProvider
 
getDeserializer(TypeHolder<T>) - Method in class io.servicetalk.data.protobuf.ProtobufSerializationProvider
 
getDeserializer(Class<T>) - Method in interface io.servicetalk.serialization.api.SerializationProvider
Provide a StreamingDeserializer instance that can deserialize instances of T.
getDeserializer(TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.SerializationProvider
Provide a StreamingDeserializer instance that can deserialize instances of T.
getDouble(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 64-bit floating point number at the specified absolute index in this buffer.
getDouble(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getEffectiveRequestUri(ConnectionContext, HttpRequestMetaData, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils
Get the effective request URI for the provided ConnectionContext and HttpRequestMetaData.
getEffectiveRequestUri(ConnectionContext, HttpRequestMetaData, String, String, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils
Get the effective request URI for the provided ConnectionContext and HttpRequestMetaData.
getEffectiveRequestUri(HttpRequestMetaData, String, String, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils
Get the effective request URI for the provided HttpRequestMetaData.
getFailed(boolean) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getFloat(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 32-bit floating point number at the specified absolute index in this buffer.
getFloat(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getForeverSuspended(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.CancellableResources
 
getImmutableMapOrNull() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
getImmutableMapOrNull() - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
getInt(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 32-bit integer at the specified absolute index in this buffer.
getInt(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getIntLE(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 32-bit integer at the specified absolute index in this buffer with Little Endian Byte Order.
getIntLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getJson() - Method in class io.servicetalk.http.router.jersey.AbstractResourceTest
 
getJson() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getJson() - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getJson() - Method in class io.servicetalk.http.router.jersey.resources.SynchronousResources
 
getJsonAsyncResponse(AsyncResponse) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getJsonResponseContentLengthExtractor() - Method in class io.servicetalk.http.router.jersey.AbstractNonParameterizedJerseyStreamingHttpServiceTest
 
getKey() - Method in exception io.servicetalk.client.api.partition.DuplicateAttributeException
Get the PartitionAttributes.Key which corresponds to the exception.
getLong(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 64-bit long integer at the specified absolute index in this buffer.
getLong(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getLongLE(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 64-bit long integer at the specified absolute index in this buffer in Little Endian Byte Order.
getLongLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getMapSingle() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getMapSingle(boolean) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getMedium(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 24-bit medium integer at the specified absolute index in this buffer.
getMedium(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getMediumLE(int) - Method in interface io.servicetalk.buffer.api.Buffer
Gets a 24-bit medium integer at the specified absolute index in this buffer in the Little Endian Byte Order.
getMediumLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
getMessage() - Method in exception io.servicetalk.transport.netty.internal.CloseHandler.CloseEventObservedException
 
getName() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
 
getOffloadedBlocked() - Method in class io.servicetalk.http.router.jersey.resources.CancellableResources
 
getOperationName(String, HttpRequestMetaData) - Method in class io.servicetalk.opentracing.http.TracingHttpServiceFilter
Get the operation name to build the span with.
getOption(SocketOption<T>, ChannelConfig, Long) - Static method in class io.servicetalk.transport.netty.internal.SocketOptionUtils
Get a SocketOption value from ChannelConfig.
getPartitionSelector() - Method in exception io.servicetalk.client.api.partition.ClosedPartitionException
Get the PartitionAttributes that was used to select the partition.
getPartitionSelector() - Method in exception io.servicetalk.client.api.partition.UnknownPartitionException
Get the PartitionAttributes that was used to select the partition.
getPath() - Method in class io.servicetalk.transport.api.DomainSocketAddress
The file system path used to bind/connect for a UNIX domain socket.
getPojoSingle() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getPojoSingle(boolean) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getReadOnlyContextData() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
getReadOnlyContextData() - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
getRequestBufferPublisherInputStream(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties
Get the BufferPublisherInputStream associated with the request.
getRequestCancellable(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties
Get the request Cancellable.
getResponseBufferPublisher(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties
Get the response Publisher<Buffer>.
getResponseCompletionStage(HttpHeaders) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getResponseExecutionStrategy(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties
Get the response HttpExecutionStrategy used for offloading.
getResponseSingle() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getResponseSingle(boolean) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getResponseSinglePublisherEntity() - Method in class io.servicetalk.http.router.jersey.AsynchronousResourceTest
 
getResponseSinglePublisherEntity(int) - Method in class io.servicetalk.http.router.jersey.resources.AsynchronousResources
 
getRouteExecutionStrategyAnnotation(Method, Class<?>) - S