Index

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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ABORTED - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode: Aborted, typically due to a concurrency issue (think CAS).
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.
accept(int, int) - Method in interface io.servicetalk.dns.discovery.netty.ServiceDiscovererUtils.TwoIntsConsumer: Performs this operation on the given arguments.
accept(long, long) - Method in interface io.servicetalk.concurrent.api.LongBinaryConsumer: Evaluates this consumer on the given arguments.
accept(ConnectionContext) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor: Deprecated.

Evaluate the passed ConnectionContext to accept or reject.
accept(ConnectionContext) - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
accept(ConnectionInfo) - Method in interface io.servicetalk.transport.api.EarlyConnectionAcceptor: Accept or reject an incoming connection.
accept(ConnectionInfo) - Method in interface io.servicetalk.transport.api.LateConnectionAcceptor: Accept or reject an incoming connection.
accept(Void, Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
accept(Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer: Same as StatelessTrailersTransformer.accept(Void, Object) but without the state.
accept(State, Payload) - Method in interface io.servicetalk.http.api.TrailersTransformer: Accepts a TrailersTransformer.
accept(X, Y, Z) - Method in interface io.servicetalk.concurrent.api.TriConsumer: Performs this operation on the given arguments.
ACCEPT - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept"
ACCEPT_ALL - Static variable in interface io.servicetalk.transport.api.ConnectionAcceptor: Deprecated.

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"
acceptConnections(boolean) - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
acceptConnections(boolean) - Method in interface io.servicetalk.transport.api.ServerListenContext: Toggles the server's ability to accept new connections.
acceptConnections(boolean) - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
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() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.ACCEPTED response.
Accepted - Enum constant in enum class io.servicetalk.client.api.internal.RequestConcurrencyController.Result: Deprecated.

Selecting the resource succeeded.
Accepted - Enum constant in enum class io.servicetalk.client.api.RequestConcurrencyController.Result: Selecting the resource succeeded.
ACCEPTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 202 Accepted
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.
ackTimeout() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig.KeepAlivePolicy: Duration to wait for acknowledgment from the peer after a ping is sent.
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.
activate(Span) - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
activateSpan(Span) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
activeSpan() - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
activeSpan() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
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: Deprecated.

StreamingHttpService that adapts another service to the streaming programming model.
add(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap: Deprecated.
add(PartitionAttributes) - Method in interface io.servicetalk.client.api.partition.PartitionMap: Deprecated.

Add a new PartitionAttributes that is absolutely specified.
add(PartitionAttributes.Key<T>, T) - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder: Deprecated.
add(PartitionAttributes.Key<T>, T) - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder: Deprecated.

Add a key/value pair to this builder.
add(BufferDecoder) - Method in class io.servicetalk.encoding.api.BufferDecoderGroupBuilder: Add a new BufferDecoder to the BufferDecoderGroup built by this builder.
add(BufferDecoder, boolean) - Method in class io.servicetalk.encoding.api.BufferDecoderGroupBuilder: Add a new BufferDecoder to the BufferDecoderGroup built by this builder.
add(HttpHeaders) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
add(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds all header names and values of headers to this object.
add(CharSequence, CharSequence) - 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, CharSequence...) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
add(CharSequence, CharSequence...) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds new headers with the specified name and values.
add(CharSequence, Iterable<? extends CharSequence>) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
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 class io.servicetalk.http.api.EmptyHttpHeaders
add(CharSequence, Iterator<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds new headers with the specified name and values.
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.
addBlockingRequestStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingRequestStreamingRoute to this factory.
addBlockingRequestStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingRequestStreamingRoute to this factory.
addBlockingRequestStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addBlockingRequestStreamingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, BlockingRequestStreamingRoute).
addBlockingRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addBlockingStreamingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, BlockingStreamingRoute).
addBlockingResponseStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingResponseStreamingRoute to this factory.
addBlockingResponseStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingResponseStreamingRoute to this factory.
addBlockingResponseStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addBlockingResponseStreamingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, BlockingResponseStreamingRoute).
addBlockingResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addBlockingResponseStreamingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, BlockingResponseStreamingRoute).
addBlockingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRoute<Req, Resp>) - 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: Deprecated.
Use GrpcRoutes.addBlockingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, BlockingRoute).
addBlockingRoute(String, Class<?>, String, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addBlockingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, BlockingRoute).
addBlockingService(Health.BlockingHealthService) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
addBlockingStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBlockingStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingStreamingRoute<Req, Resp>) - 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: Deprecated.
Use GrpcRoutes.addBlockingStreamingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, BlockingStreamingRoute).
addBlockingStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addBlockingStreamingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, BlockingStreamingRoute).
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(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addCookie(HttpCookiePair) - Method in interface 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(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a cookie.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequest
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponse
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addCookie(HttpCookiePair) - 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.BlockingStreamingHttpRequest
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a cookie with the specified name and value.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a cookie with the specified name and value.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
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 interface 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 interface 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>, T) - 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, Iterable<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, Iterable<String>) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequest
addQueryParameters(String, 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.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: Same as InMemorySpanBuilder.addReference(String, SpanContext) but requires a InMemorySpanContext.
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
addRequestStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.RequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addRequestStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.RequestStreamingRoute<Req, Resp>) - 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: Deprecated.
Use GrpcRoutes.addRequestStreamingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, RequestStreamingRoute).
addRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addRequestStreamingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, RequestStreamingRoute).
addResponseStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.ResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
addResponseStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.ResponseStreamingRoute<Req, Resp>) - 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: Deprecated.
Use GrpcRoutes.addResponseStreamingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, ResponseStreamingRoute).
addResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addResponseStreamingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, ResponseStreamingRoute).
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.
addRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.Route<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.Route to this factory.
addRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.Route<Req, Resp>) - 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: Deprecated.
Use GrpcRoutes.addRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, Route).
addRoute(String, Class<?>, String, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addRoute(Class, MethodDescriptor, BufferDecoderGroup, List, Route).
addService(Health.BlockingHealthService) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder: Deprecated.
Use Health.ServiceFactory.Builder.addBlockingService(io.servicetalk.health.v1.Health.BlockingHealthService).
addService(Health.HealthService) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addSetCookie(HttpSetCookie) - Method in interface 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(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a set-cookie.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequest
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponse
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addSetCookie(HttpSetCookie) - 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.BlockingStreamingHttpRequest
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addSetCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a set-cookie with the specified name and value.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a set-cookie with the specified name and value.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.StreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.StreamingRoute to this factory.
addStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.StreamingRoute<Req, Resp>) - 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: Deprecated.
Use GrpcRoutes.addStreamingRoute(GrpcExecutionStrategy, MethodDescriptor, BufferDecoderGroup, List, StreamingRoute)
addStreamingRoute(String, Class<?>, String, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Deprecated.
Use GrpcRoutes.addStreamingRoute(Class, MethodDescriptor, BufferDecoderGroup, List, StreamingRoute).
addSuppressed(Throwable, Throwable) - Static method in class io.servicetalk.utils.internal.ThrowableUtils: Adds suppressed exception avoiding self-suppression.
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(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Adds two positive ints and returns Integer.MAX_VALUE if overflow occurs.
addWithOverflowProtection(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Adds two positive longs and returns 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(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).
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).
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).
addWithUnderOverflowProtection(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Add two longs and prevent [under|over]flow which is defined as if both x and y have the same sign but the result of x + y has a different sign.
addWithUnderOverflowProtection(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Add two longs and prevent [under|over]flow which is defined as if both x and y have the same sign but the result of x + y has a different sign.
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator: Advance the HeaderUtils.CookiesByNameIterator.cookieHeaderValue() to the next HttpHeaderNames.COOKIE header value.
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator: Advance the HeaderUtils.CookiesIterator.cookieHeaderValue() to the next HttpHeaderNames.COOKIE header value.
advertisedMessageEncoding() - Method in interface io.servicetalk.encoding.api.BufferDecoderGroup: Get the combined encoding to advertise.
advertisedMessageEncoding() - Method in class io.servicetalk.encoding.api.EmptyBufferDecoderGroup
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() - Method in interface io.servicetalk.concurrent.api.ScanLifetimeMapper: Invoked after a terminal signal PublisherSource.Subscriber.onError(Throwable) or PublisherSource.Subscriber.onComplete() or Cancellable.cancel().
afterFinally() - Method in interface io.servicetalk.concurrent.api.ScanWithLifetimeMapper: Deprecated.

Invoked after a terminal signal PublisherSource.Subscriber.onError(Throwable) or PublisherSource.Subscriber.onComplete() or Cancellable.cancel().
afterFinally(SingleTerminalSignalConsumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single: Invokes the corresponding method on afterFinally SingleTerminalSignalConsumer argument after any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) - invokes SingleTerminalSignalConsumer.onSuccess(Object) SingleSource.Subscriber.onError(Throwable) - invokes SingleTerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes SingleTerminalSignalConsumer.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
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(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Publisher: Invokes the corresponding method on afterFinally TerminalSignalConsumer argument after any of the following terminal methods are called: PublisherSource.Subscriber.onComplete() - invokes TerminalSignalConsumer.onComplete() PublisherSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for PublisherSource.Subscriptions/PublisherSource.Subscribers of the returned Publisher.
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(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(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(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.
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<? 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.Completable: Invokes the onSubscribe Consumer argument after CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
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"
algorithmId() - Method in interface io.servicetalk.transport.api.CertificateCompressionAlgorithm: Get the unique identifier for this algorithm.
allocateMemory(long) - Static method in class io.servicetalk.utils.internal.PlatformDependent: Allocates direct memory.
allocator - Variable in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
ALLOW - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "allow"
allowDropRequestTrailers(boolean) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
allowDropRequestTrailers(boolean) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Provide a hint if request trailers are allowed to be dropped.
allowDropResponseTrailers(boolean) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
allowDropResponseTrailers(boolean) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Provide a hint if response trailers are allowed to be dropped.
allowedMethods() - Method in interface io.servicetalk.http.api.RedirectConfig: HttpRequestMethods that are allowed to follow redirects.
allowedMethods(HttpRequestMethod...) - Method in class io.servicetalk.http.api.RedirectConfigBuilder: Sets HttpRequestMethods that are allowed to follow redirects.
allowedStatuses() - Method in interface io.servicetalk.http.api.RedirectConfig: HttpResponseStatuses that are allowed to follow redirects.
allowedStatuses(HttpResponseStatus...) - Method in class io.servicetalk.http.api.RedirectConfigBuilder: Sets HttpResponseStatuses that are allowed to follow redirects.
allowLFWithoutCR() - Method in class io.servicetalk.http.netty.H1SpecExceptions: Allow LF without a proceeding CR as described in HTTP/1.x Message Parsing Robustness:
allowLFWithoutCR(boolean) - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder: Allow LF without a proceeding CR as described in HTTP/1.x Message Parsing Robustness:
allowNonRelativeRedirects() - Method in interface io.servicetalk.http.api.RedirectConfig: Tells if redirection should follow non-relative redirects (if supported by the underlying client implementation).
allowNonRelativeRedirects(boolean) - Method in class io.servicetalk.http.api.RedirectConfigBuilder: Allows non-relative redirects (if supported by the underlying client implementation).
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(boolean) - 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
alpnProtocols() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
alpnProtocols() - Method in interface io.servicetalk.transport.api.SslConfig: Get the TLS ALPN protocols.
alpnProtocols(String...) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Set the TLS ALPN protocols.
alpnProtocols(List<String>) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Set the TLS ALPN protocols.
ALREADY_EXISTS - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode: Some entity that we attempted to create already exists.
ALREADY_REPORTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 208 Already Reported
alreadyReported() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.ALREADY_REPORTED response.
alreadyReported() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.ALREADY_REPORTED response.
alreadyReported() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.ALREADY_REPORTED response.
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(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<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<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(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.
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.
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(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<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<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.
append(ConnectionFactoryFilter<ResolvedAddress, C>) - Method in interface io.servicetalk.client.api.ConnectionFactoryFilter: Deprecated.
consider using higher level client builders to append filters.
append(GrpcClientBuilder.HttpInitializer<U, R>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.HttpInitializer: Appends the passed GrpcClientBuilder.HttpInitializer to this GrpcClientBuilder.HttpInitializer such that this instance is applied first and then the argument's GrpcClientBuilder.HttpInitializer.
append(GrpcServerBuilder.HttpInitializer) - Method in interface io.servicetalk.grpc.api.GrpcServerBuilder.HttpInitializer: Appends the passed GrpcServerBuilder.HttpInitializer to this GrpcServerBuilder.HttpInitializer such that this instance is applied first and then the argument's GrpcServerBuilder.HttpInitializer.
append(HttpExecutionStrategyInfluencer) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Deprecated.

Append another HttpExecutionStrategyInfluencer to this chain.
append(MultiAddressHttpClientBuilder.SingleAddressInitializer<U, R>) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder.SingleAddressInitializer: Appends the passed MultiAddressHttpClientBuilder.SingleAddressInitializer to this MultiAddressHttpClientBuilder.SingleAddressInitializer such that this MultiAddressHttpClientBuilder.SingleAddressInitializer is applied first and then the passed MultiAddressHttpClientBuilder.SingleAddressInitializer.
append(PartitionedHttpClientBuilder.SingleAddressInitializer<U, R>) - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder.SingleAddressInitializer: Deprecated.

Appends the passed PartitionedHttpClientBuilder.SingleAddressInitializer to this PartitionedHttpClientBuilder.SingleAddressInitializer such that this PartitionedHttpClientBuilder.SingleAddressInitializer is applied first and then the passed PartitionedHttpClientBuilder.SingleAddressInitializer.
append(PartitionHttpClientBuilderConfigurator<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator: Deprecated.

Appends the passed PartitionHttpClientBuilderConfigurator to this PartitionHttpClientBuilderConfigurator such that this PartitionHttpClientBuilderConfigurator is applied first and then the passed PartitionHttpClientBuilderConfigurator.
append(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor: Deprecated.

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: Deprecated.

Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(ExecutionStrategyInfluencer<?>) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Deprecated.

Append another ExecutionStrategyInfluencer to this chain.
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.
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.
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
appendClientFilter(StreamingHttpClientFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the HttpClient created by this builder.
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the HttpClient created by this builder, for every request that passes the provided Predicate.
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Deprecated.
use HttpServerBuilder.appendLateConnectionAcceptor(LateConnectionAcceptor) instead.
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the ConnectionFactory used by this builder.
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the StreamingHttpConnection created by this builder.
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the StreamingHttpConnection created by this builder, for every request that passes the provided Predicate.
appendEarlyConnectionAcceptor(EarlyConnectionAcceptor) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
appendEarlyConnectionAcceptor(EarlyConnectionAcceptor) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Appends the EarlyConnectionAcceptor to be called when a new connection has been created.
appendIfInfluencer(Object) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Deprecated.

If the passed mayBeInfluencer is an ExecutionStrategyInfluencer then add it to this chain.
appendLateConnectionAcceptor(LateConnectionAcceptor) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
appendLateConnectionAcceptor(LateConnectionAcceptor) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Appends the LateConnectionAcceptor to be called when a new connection has been created.
appendNonOffloadingServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
appendNonOffloadingServiceFilter(StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Appends a non-offloading filter to the chain of filters used to decorate the StreamingHttpService used by this builder.
appendNonOffloadingServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
appendNonOffloadingServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Appends a non-offloading filter to the chain of filters used to decorate the StreamingHttpService used by this builder, for every request that passes the provided Predicate.
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(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
appendServiceFilter(StreamingHttpServiceFilterFactory) - Method in interface 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.DelegatingHttpServerBuilder
appendServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in interface 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.
APPLICATION_GRPC - Static variable in class io.servicetalk.grpc.api.GrpcHeaderValues: application/grpc value for content-type header.
APPLICATION_GRPC_PROTO - Static variable in class io.servicetalk.grpc.api.GrpcHeaderValues: application/grpc+proto value for content-type header.
APPLICATION_JSON - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "application/json"
APPLICATION_X_PROTOBUF - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes: "application/x-protobuf".
APPLICATION_X_PROTOBUF - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "application/x-protobuf"
APPLICATION_X_PROTOBUF_TYPE - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes: "application/x-protobuf".
APPLICATION_X_PROTOBUF_VAR_INT - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes: "application/x-protobuf-var-int" base 128 VarInt protobuf encoding.
APPLICATION_X_PROTOBUF_VAR_INT - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "application/x-protobuf-var-int" base 128 VarInt protobuf encoding.
APPLICATION_X_PROTOBUF_VAR_INT_TYPE - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes: "application/x-protobuf-var-int" base 128 VarInt protobuf encoding.
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(boolean, StreamingHttpRequest, StreamingHttpResponse, StreamingHttpRequest) - Method in interface io.servicetalk.http.api.RedirectConfig.RedirectRequestTransformer: Applies transformations for the pre-initialized redirect request.
apply(int, T) - Method in interface io.servicetalk.concurrent.api.BiIntFunction: Evaluates this function on the given arguments.
apply(PartitionAttributes, ServiceDiscoverer<U, R, ServiceDiscovererEvent<R>>) - Method in interface io.servicetalk.client.api.internal.DefaultPartitionedClientGroup.PartitionedClientFactory: Deprecated.

Create a partitioned client.
apply(CompletableSource.Subscriber) - Method in interface io.servicetalk.concurrent.api.CompletableOperator: Implementation of this operator.
apply(PublisherSource.Subscriber<? super Iterable<T>>) - Method in class io.servicetalk.serializer.utils.FramedDeserializerOperator
apply(PublisherSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherOperator: Implementation of this operator.
apply(SingleSource.Subscriber<? super StreamingHttpResponse>) - Method in class io.servicetalk.http.utils.BeforeFinallyHttpOperator
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherToSingleOperator: Implementation of this operator.
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.SingleOperator: Implementation of this operator.
apply(HttpRequestMetaData) - Method in interface io.servicetalk.http.utils.TimeoutFromRequest: Deprecated.

Determine timeout duration, if present, from a request and/or apply default timeout durations.
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.SplittingFlushStrategy: Deprecated.
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(T1, T2, T3) - Method in interface io.servicetalk.concurrent.api.Function3: Applies the function to the given arguments.
apply(T1, T2, T3, T4) - Method in interface io.servicetalk.concurrent.api.Function4: Applies the function to the given arguments.
appSerializerAsciiFixLen() - Static method in class io.servicetalk.http.api.HttpSerializers: Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.US_ASCII encoding using fixed int length delimited framing.
appSerializerAsciiVarLen() - Static method in class io.servicetalk.http.api.HttpSerializers: Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.US_ASCII encoding using variable int length delimited framing.
appSerializerFixLen(Charset) - Static method in class io.servicetalk.http.api.HttpSerializers: Creates a HttpStreamingSerializerDeserializer that serializes Strings with charset encoding using fixed int length delimited framing.
appSerializerUtf8FixLen() - Static method in class io.servicetalk.http.api.HttpSerializers: Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.UTF_8 encoding using fixed int length delimited framing.
appSerializerUtf8VarLen() - Static method in class io.servicetalk.http.api.HttpSerializers: Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.UTF_8 encoding using variable int length delimited framing.
appSerializerVarLen(Charset) - Static method in class io.servicetalk.http.api.HttpSerializers: Creates a HttpStreamingSerializerDeserializer that serializes Strings with charset encoding using fixed int length delimited framing.
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: Deprecated.
This internal class will be removed in the future releases without a replacement. If you depend on it, consider copying into your codebase.
asBlockingClient() - Method in interface io.servicetalk.grpc.api.GrpcClient: Converts this GrpcClient to a blocking client.
asBlockingClient() - Method in interface io.servicetalk.health.v1.Health.HealthClient
asBlockingClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient: Convert this BlockingStreamingHttpClient to the BlockingHttpClient API.
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: Convert this BlockingStreamingHttpConnection to the BlockingHttpConnection API.
asBlockingConnection() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpLoadBalancedConnection
asBlockingConnection() - Method in interface io.servicetalk.http.api.HttpConnection: Convert this HttpConnection to the BlockingHttpConnection API.
asBlockingConnection() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
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: Convert this StreamingHttpConnection to the BlockingHttpConnection API.
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient: Convert this BlockingHttpClient to the BlockingStreamingHttpClient API.
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: Convert this StreamingHttpClient to the BlockingStreamingHttpClient API.
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection: Convert this BlockingHttpConnection to the BlockingStreamingHttpConnection API.
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpLoadBalancedConnection
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.HttpConnection: Convert this HttpConnection to the BlockingStreamingHttpConnection API.
asBlockingStreamingConnection() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
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: Convert this StreamingHttpConnection to the BlockingStreamingHttpConnection API.
asChildOf(Span) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
asChildOf(SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
asciiStringIndexOf(CharSequence, char, int) - Static method in class io.servicetalk.buffer.api.CharSequences: Deprecated.
Use CharSequences.indexOf(CharSequence, char, int).
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.
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: Convert this BlockingStreamingHttpConnection to the HttpConnection API.
asConnection() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpLoadBalancedConnection
asConnection() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
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: Deprecated.
Use GrpcStatusException(GrpcStatus).
asException(Supplier<Status>) - Method in class io.servicetalk.grpc.api.GrpcStatus: Deprecated.
Use GrpcStatusException.of(Status).
asExecutor() - Method in interface io.servicetalk.transport.netty.internal.NettyIoExecutor: Deprecated.
IoExecutor now implements Executor so this method is redundant.
asInputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer: Return an InputStream that wraps the given Buffer.
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() - Method in class io.servicetalk.tcp.netty.internal.TcpClientConfig: Create a read only view of this object.
asReadOnly() - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig: Create a read only view of this object.
asSafeObserver(TransportObserver) - Static method in class io.servicetalk.transport.api.TransportObservers: Coverts passed TransportObserver to a safe version that catches and logs all exceptions, but does not rethrow them.
assertNoAsyncErrors(String, Queue<? extends Throwable>) - Static method in class io.servicetalk.test.resources.TestUtils: Helper method to check if a given Queue contains any errors, usually produced through async sources.
assertNoAsyncErrors(Queue<? extends Throwable>) - Static method in class io.servicetalk.test.resources.TestUtils: Helper method to check if a given Queue contains any errors, usually produced through async sources.
assignConnectionError(Channel, Throwable) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils: Assigns a Throwable to the passed Channel to report it as a closure reason.
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: Convert this BlockingStreamingHttpClient to the StreamingHttpClient API.
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: Convert this BlockingHttpConnection to the StreamingHttpConnection API.
asStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection: Convert this BlockingStreamingHttpConnection to the StreamingHttpConnection API.
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.
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.
available() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
AVAILABLE - Static variable in class io.servicetalk.client.api.ServiceDiscovererEvent.Status: Signifies the ServiceDiscovererEvent.address() is available for use in connection establishment.
await(CountDownLatch) - Static method in class io.servicetalk.concurrent.test.internal.AwaitUtils: Await a CountDownLatch until the latch is counted down, throws unchecked InterruptedException.
await(CountDownLatch, long, TimeUnit) - Static method in class io.servicetalk.concurrent.test.internal.AwaitUtils: Await a CountDownLatch until the latch is counted down or the given time duration expires, throws unchecked InterruptedException.
awaitOnComplete() - Method in class io.servicetalk.concurrent.test.internal.TestCompletableSubscriber: Block until a terminal signal is received, throws if TestCompletableSubscriber.onError(Throwable) and returns normally if TestCompletableSubscriber.onComplete().
awaitOnComplete() - Method in class io.servicetalk.concurrent.test.internal.TestPublisherSubscriber: Block until a terminal signal is received, throws if TestPublisherSubscriber.onError(Throwable) and returns normally if TestPublisherSubscriber.onComplete().
awaitOnError() - Method in class io.servicetalk.concurrent.test.internal.TestCompletableSubscriber: Block until a terminal signal is received, throws if TestCompletableSubscriber.onComplete() and returns normally if TestCompletableSubscriber.onError(Throwable).
awaitOnError() - Method in class io.servicetalk.concurrent.test.internal.TestPublisherSubscriber: Block until a terminal signal is received, throws if TestPublisherSubscriber.onComplete() and returns normally if TestPublisherSubscriber.onError(Throwable).
awaitOnError() - Method in class io.servicetalk.concurrent.test.internal.TestSingleSubscriber: Block until a terminal signal is received, throws if TestSingleSubscriber.onSuccess(Object) and returns normally if TestSingleSubscriber.onError(Throwable).
awaitOnSuccess() - Method in class io.servicetalk.concurrent.test.internal.TestSingleSubscriber: Block until a terminal signal is received, throws if TestSingleSubscriber.onError(Throwable) and returns normally if TestSingleSubscriber.onSuccess(Object).
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.test.internal.TestCompletableSubscriber: Block until TestCompletableSubscriber.onSubscribe(Cancellable).
awaitSubscription() - Method in class io.servicetalk.concurrent.test.internal.TestPublisherSubscriber: Block until PublisherSource.Subscriber.onSubscribe(Subscription).
awaitSubscription() - Method in class io.servicetalk.concurrent.test.internal.TestSingleSubscriber: Block until TestSingleSubscriber.onSubscribe(Cancellable).
awaitTermination(Future<Void>) - Static method in class io.servicetalk.concurrent.internal.FutureUtils: Await the completion of the passed Future.
AwaitUtils - Class in io.servicetalk.concurrent.test.internal: Utilities to do blocking await calls for tests.

B

B3KeyValueFormatter<T> - Class in io.servicetalk.opentracing.inmemory
B3KeyValueFormatter(TriConsumer<T, CharSequence, CharSequence>, BiFunction<T, CharSequence, CharSequence>, boolean) - Constructor for class io.servicetalk.opentracing.inmemory.B3KeyValueFormatter: Create a new instance.
BACKGROUND - Enum constant in enum class io.servicetalk.http.netty.HttpClients.DiscoveryStrategy: Resolves an address in a background.
backgroundExecutor(Executor) - Method in class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder
backgroundExecutor(Executor) - Method in interface io.servicetalk.loadbalancer.RoundRobinLoadBalancerBuilder: This LoadBalancer may monitor hosts to which connection establishment has failed using health checks that run in the background.
backgroundExecutor(Executor) - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory.Builder: Deprecated.
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.
baggageItems() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemorySpanContext
BASE64 - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "base64"
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 Interface 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.
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(SingleTerminalSignalConsumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single: Invokes the corresponding method on beforeFinally SingleTerminalSignalConsumer argument before any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) - invokes SingleTerminalSignalConsumer.onSuccess(Object) SingleSource.Subscriber.onError(Throwable) - invokes SingleTerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes SingleTerminalSignalConsumer.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
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(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Publisher: Invokes the corresponding method on beforeFinally TerminalSignalConsumer argument before any of the following terminal methods are called: PublisherSource.Subscriber.onComplete() - invokes TerminalSignalConsumer.onComplete() PublisherSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for PublisherSource.Subscriptions/PublisherSource.Subscribers of the returned Publisher.
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(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(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(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.
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(TerminalSignalConsumer, boolean) - 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<? 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.Completable: Invokes the onSubscribe Consumer argument before CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
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(SocketAddress, ReadOnlyTcpServerConfig, boolean, ExecutionContext<?>, InfluencerConnectionAcceptor, BiFunction<Channel, ConnectionObserver, Single<CC>>, Consumer<CC>) - Static method in class io.servicetalk.tcp.netty.internal.TcpServerBinder: Deprecated.
use the bind method with early and late acceptors instead.
bind(SocketAddress, ReadOnlyTcpServerConfig, ExecutionContext<?>, InfluencerConnectionAcceptor, BiFunction<Channel, ConnectionObserver, Single<CC>>, Consumer<CC>, EarlyConnectionAcceptor, LateConnectionAcceptor) - 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.
bindService() - Method in interface io.servicetalk.grpc.api.GrpcBindableService: Return an appropriate service factory bound to this service.
bindService() - Method in interface io.servicetalk.health.v1.Health.BlockingHealthService: Makes a Health.ServiceFactory bound to this instance implementing Health.BlockingHealthService
bindService() - Method in interface io.servicetalk.health.v1.Health.HealthService: Makes a Health.ServiceFactory bound to this instance implementing Health.HealthService
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.
blockingInvocation(Completable) - Static method in class io.servicetalk.concurrent.api.internal.BlockingUtils: Subscribes a Completable immediately and awaits result.
blockingInvocation(Single<T>) - Static method in class io.servicetalk.concurrent.api.internal.BlockingUtils: Subscribes a Single immediately and awaits result.
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().
BlockingStreamingGrpcServerResponse<T> - Interface in io.servicetalk.grpc.api: The response for streaming use-cases that provides ability to defer sending response meta-data and write the payload to an GrpcPayloadWriter.
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: A combination of BlockingStreamingHttpRequestFactory and BlockingStreamingHttpResponseFactory.
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 - Interface 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: Returns the BlockingStreamingHttpResponseFactory associated with this HttpServiceContext.
BlockingUtils - Class in io.servicetalk.concurrent.api.internal: Common utility functions to unwrap ExecutionException from async operations.
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(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.
Buffer - Interface in io.servicetalk.buffer.api: An arbitrary and sequential accessible sequence of zero or more bytes (octets).
bufferAllocator() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
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.http.api.DelegatingHttpServerBuilder
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Sets the BufferAllocator to be used by this server.
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Deprecated.
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Sets the BufferAllocator to use.
BufferAllocator - Interface in io.servicetalk.buffer.api: An API to allocate Buffers.
BufferAllocators - Class in io.servicetalk.buffer.netty: Available BufferAllocators.
BufferDecoder - Interface in io.servicetalk.encoding.api: Used to decode buffers for aggregated and streaming use cases.
bufferDecoderGroup() - Method in class io.servicetalk.grpc.api.GrpcClientFactory: Get the supported BufferDecoderGroup for this client factory.
bufferDecoderGroup(BufferDecoderGroup) - Method in class io.servicetalk.grpc.api.GrpcClientFactory: Sets the supported BufferDecoderGroup for this client factory.
bufferDecoderGroup(BufferDecoderGroup) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
BufferDecoderGroup - Interface in io.servicetalk.encoding.api: A group of BufferDecoders used when multiple options may be supported.
BufferDecoderGroupBuilder - Class in io.servicetalk.encoding.api: Builder for BufferDecoderGroups.
BufferDecoderGroupBuilder() - Constructor for class io.servicetalk.encoding.api.BufferDecoderGroupBuilder: Create a new instance.
BufferDecoderGroupBuilder(int) - Constructor for class io.servicetalk.encoding.api.BufferDecoderGroupBuilder: Create a new instance.
bufferEncoder(SerializerDeserializer<Buffer>, StreamingSerializerDeserializer<Buffer>, CharSequence) - Static method in class io.servicetalk.encoding.netty.NettyBufferEncoders: Create a BufferEncoderDecoder given the underlying SerializerDeserializer and StreamingSerializerDeserializer implementations.
BufferEncoder - Interface in io.servicetalk.encoding.api: Used to encode buffers for aggregated and streaming use cases.
BufferEncoderDecoder - Interface in io.servicetalk.encoding.api: A BufferEncoder and BufferDecoder.
bufferEncoders(List<BufferEncoder>) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
BufferEncodingException - Exception in io.servicetalk.encoding.api: A specialization of SerializationException used to indicate an encoding exception.
BufferEncodingException(String) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException: Create a new instance.
BufferEncodingException(String, Throwable) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException: New instance.
BufferEncodingException(String, Throwable, boolean, boolean) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException: New instance.
BufferEncodingException(Throwable) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException: New instance.
BufferHandler - Class in io.servicetalk.transport.netty.internal: Deprecated.
This API is going to be removed in future releases with no planned replacement. If it cannot be removed from your application, consider copying it into your codebase.
BufferHolder - Interface in io.servicetalk.buffer.api: Deprecated.
This API is going to be removed in future releases with no planned replacement. If it cannot be removed from your application, consider copying it into your codebase.
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.
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() - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder: Deprecated.
build() - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder: Deprecated.

Build a PartitionAttributes corresponding to the previous PartitionAttributesBuilder.add(PartitionAttributes.Key, Object) calls.
build() - Method in class io.servicetalk.encoding.api.BufferDecoderGroupBuilder: Build a new BufferDecoderGroup.
build() - Method in class io.servicetalk.encoding.netty.ZipCompressionBuilder: Build and return an instance of the SerializerDeserializer with the configuration of the builder.
build() - Method in class io.servicetalk.encoding.netty.ZipContentCodecBuilder: Deprecated.

Build and return an instance of the ContentCodec with the configuration of the builder.
build() - Method in class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder: Builds a new GrpcExecutionStrategy.
build() - Method in class io.servicetalk.grpc.protobuf.ProtoBufSerializationProviderBuilder: Deprecated.

Builds a new GrpcSerializationProvider containing all the message types registered with this builder.
build() - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
build() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
build() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
build() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
build() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
build() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
build() - Method in class io.servicetalk.http.api.Http2SettingsBuilder: Build the Map that represents HTTP/2 Setting.
build() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Builds a new HttpClient.
build() - Method in class io.servicetalk.http.api.HttpExecutionStrategies.Builder: Builds a new HttpExecutionStrategy.
build() - Method in class io.servicetalk.http.api.RedirectConfigBuilder
build() - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Deprecated.

Builds this chain and returns a computed HttpExecutionStrategyInfluencer that reflects the strategy of the entire 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: Builds H1ProtocolConfig.
build() - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder: Builds H1SpecExceptions.
build() - Method in class io.servicetalk.http.netty.H2KeepAlivePolicies.KeepAlivePolicyBuilder: Build a new H2ProtocolConfig.KeepAlivePolicy.
build() - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder: Builds H2ProtocolConfig.
build() - Method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter.Builder: Builds a retrying RetryingHttpRequesterFilter with this' builders configuration.
build() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters.AbstractBuilder: Build a new ContainerRequestFilter instance.
build() - Method in class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder
build() - Method in interface io.servicetalk.loadbalancer.RoundRobinLoadBalancerBuilder: Builds the LoadBalancerFactory configured by this builder.
build() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory.Builder: Deprecated.
build() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder: Builds a new OpenTelemetryOptions.
build() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder: Builds the DefaultInMemoryTracer.
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.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.api.ClientSslConfigBuilder: Build a new ClientSslConfig.
build() - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Build a new ServerSslConfig.
build() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Builds a new ExecutionContext or return the default context if none of the components are set in this builder.
build(GrpcClientFactory<Client, ?>) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
build(GrpcClientFactory<Client, ?>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder: Builds a gRPC client.
build(GrpcClientFactory<Client, ?>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.MultiClientBuilder: Builds a gRPC client.
build(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Deprecated.

Builds this chain and returns the head HttpExecutionStrategyInfluencer for the chain.
build(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the HttpService for the specified JAX-RS Application class.
build(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the HttpService for the specified JAX-RS Application.
buildARecordDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Deprecated.
buildARecordDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
buildARecordDiscoverer() - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder: Build a new ServiceDiscoverer which targets host addresses (e.g.
buildBlocking() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
buildBlocking() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
buildBlocking() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
buildBlocking() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Creates a new BlockingHttpClient.
buildBlocking(GrpcClientFactory<?, BlockingClient>) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
buildBlocking(GrpcClientFactory<?, BlockingClient>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder: Builds a blocking gRPC client.
buildBlocking(GrpcClientFactory<?, BlockingClient>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.MultiClientBuilder: Builds a blocking gRPC client.
buildBlocking(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the BlockingHttpService for the specified JAX-RS Application class.
buildBlocking(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the BlockingHttpService for the specified JAX-RS Application.
buildBlockingStreaming() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
buildBlockingStreaming() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
buildBlockingStreaming() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
buildBlockingStreaming() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Creates a new BlockingStreamingHttpClient.
buildBlockingStreaming(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the BlockingStreamingHttpService 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.
builder(String) - Static method in class io.servicetalk.dns.discovery.netty.DnsServiceDiscoverers: A new DnsServiceDiscovererBuilder instance.
builder(String) - Static method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancers: A new RoundRobinLoadBalancerBuilder instance.
Builder() - Constructor for class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder
Builder() - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder: Create a new instance.
Builder() - Constructor for class io.servicetalk.http.netty.H1SpecExceptions.Builder
Builder() - Constructor for class io.servicetalk.http.netty.RetryingHttpRequesterFilter.Builder
Builder() - Constructor for class io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory.Builder: Deprecated.
use RoundRobinLoadBalancers.builder(String) instead.
Builder() - Constructor for class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder
Builder(SingleAddressHttpClientBuilder<?, ?>) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder: Create a new HttpReporter.Builder using the passed SingleAddressHttpClientBuilder.
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(InMemoryScopeManager) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder: Constructs a builder for an DefaultInMemoryTracer.
Builder(RouteExecutionStrategyFactory<GrpcExecutionStrategy>) - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder: Deprecated.
use Health.ServiceFactory.Builder.routeExecutionStrategyFactory(RouteExecutionStrategyFactory) on the Builder instead.
Builder(RouteExecutionStrategyFactory<GrpcExecutionStrategy>, List<ContentCodec>) - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder: Deprecated.
Use Builder(RouteExecutionStrategyFactory), Health.ServiceFactory.Builder.bufferDecoderGroup(BufferDecoderGroup), and Health.ServiceFactory.Builder.bufferEncoders(List).
Builder(String, Reporter<Span>) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher.Builder: Create 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(List<ContentCodec>) - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder: Deprecated.
Use Health.ServiceFactory.Builder.bufferDecoderGroup(BufferDecoderGroup) and Health.ServiceFactory.Builder.bufferEncoders(List).
BuilderUtils - Class in io.servicetalk.transport.netty.internal: Utilities which are used for builders.
buildMulti() - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
buildMulti() - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder: Returns a GrpcClientBuilder.MultiClientBuilder to be used to create multiple clients that share the underlying transport.
buildPartial() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
buildPartial() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
buildProxy() - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder: Creates a new instance for proxy service.
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: Deprecated.
buildSrvDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
buildSrvDiscoverer() - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder: Build a new ServiceDiscoverer which queries SRV Resource Records corresponding to serviceName.
buildStreaming() - Method in class io.servicetalk.encoding.netty.ZipCompressionBuilder: Build and return an instance of the StreamingSerializerDeserializer with the configuration of the builder.
buildStreaming() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
buildStreaming() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
buildStreaming() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
buildStreaming() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Builds a new StreamingHttpClient.
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
buildStreaming(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the StreamingHttpService for the specified JAX-RS Application class.
buildStreaming(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder: Build the StreamingHttpService for the specified JAX-RS Application.
byteArraySerializer(boolean) - Static method in class io.servicetalk.serializer.utils.ByteArraySerializer: Create a new instance.
ByteArraySerializer - Class in io.servicetalk.serializer.utils: Serialize/deserialize byte[].
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(byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
bytesBefore(int, 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 class io.servicetalk.buffer.api.EmptyBuffer
bytesBefore(int, 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 class io.servicetalk.buffer.api.EmptyBuffer
bytesEstimator() - Method in interface io.servicetalk.grpc.api.SerializerDescriptor: Get a function used to estimate the serialized size (in bytes) of each object.
bytesStreamingSerializer(Consumer<HttpHeaders>) - Static method in class io.servicetalk.http.api.HttpSerializers: Create a HttpStreamingSerializer that serializes byte[].
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() - Method in class io.servicetalk.concurrent.api.Completable: Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
cache() - Method in class io.servicetalk.concurrent.api.Single: Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int) - Method in class io.servicetalk.concurrent.api.Completable: Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
cache(int) - Method in class io.servicetalk.concurrent.api.Single: Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int, boolean) - Method in class io.servicetalk.concurrent.api.Completable: Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
cache(int, boolean) - Method in class io.servicetalk.concurrent.api.Single: Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int, boolean, BiFunction<T, Throwable, Completable>) - Method in class io.servicetalk.concurrent.api.Single: Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int, boolean, Function<Throwable, Completable>) - Method in class io.servicetalk.concurrent.api.Completable: Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
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.
CacheConnectionHttpLoadBalanceFactory<ResolvedAddress> - Class in io.servicetalk.http.utils: A HttpLoadBalancerFactory that will cache successive connection creation attempts and return the same Single instead of creating a new connection each time.
CacheConnectionHttpLoadBalanceFactory(HttpLoadBalancerFactory<ResolvedAddress>, ToIntFunction<ResolvedAddress>) - Constructor for class io.servicetalk.http.utils.CacheConnectionHttpLoadBalanceFactory: Create a new instance.
calculateDifference(List<? extends T>, List<? extends T>, Comparator<T>, ServiceDiscovererUtils.TwoIntsConsumer, ServiceDiscovererEvent.Status) - Static method in class io.servicetalk.dns.discovery.netty.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: Deprecated.

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.ConcurrentUtils: Attempts to increment sourceRequestedUpdater in order to make it the same as requestNUpdater while not exceeding the limit.
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 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.ScalarValueSubscription
cancel() - Method in class io.servicetalk.concurrent.internal.SequentialCancellable
cancel() - Method in class io.servicetalk.concurrent.internal.ThreadInterruptingCancellable
CANCEL - Static variable in class io.servicetalk.http.api.Http2ErrorCode: CANCEL.
cancelCurrent() - Method in class io.servicetalk.concurrent.internal.SequentialCancellable: Cancels only the Cancellable that is currently held without side effect for any SequentialCancellable.nextCancellable(Cancellable).
CancelImmediatelySubscriber - Class in io.servicetalk.concurrent.internal: A PublisherSource.Subscriber that invokes Cancellable.cancel() in PublisherSource.Subscriber.onSubscribe(Subscription).
Cancellable - Interface in io.servicetalk.concurrent: An entity that can be cancelled.
CANCELLED - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode: Cancelled (typically by caller).
capacity() - Method in interface io.servicetalk.buffer.api.Buffer: Returns the number of bytes (octets) this buffer can contain.
capacity() - Method in class io.servicetalk.buffer.api.EmptyBuffer
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(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
capturedRequestHeaders() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions: List of request headers to be captured as extra span attributes.
capturedRequestHeaders(List<String>) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder: Add the headers to be captured as extra span attributes.
capturedResponseHeaders() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions: List of response headers to be captured as extra span attributes.
capturedResponseHeaders(List<String>) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder: Add the headers to be captured as extra span attributes.
caseInsensitiveHashCode(CharSequence) - Static method in class io.servicetalk.buffer.api.CharSequences: Calculate a hash code of a byte array assuming ASCII character encoding.
cast(Class<R>) - Method in class io.servicetalk.concurrent.api.Publisher: Cast this Publisher from type Publisher to type Publisher.
cast(Class<R>) - Method in class io.servicetalk.concurrent.api.Single: Cast this Single from type Single to type Single.
catchPayloadFailure(Void, 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 TrailersTransformer 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: Deprecated.
Use GrpcStatusException.fromThrowable(Throwable) to create a GrpcStatusException then Throwable.getCause().
CertificateCompressionAlgorithm - Interface in io.servicetalk.transport.api: Represents an algorithm that can compress and decompress SSL certificates.
certificateCompressionAlgorithms() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
certificateCompressionAlgorithms() - Method in interface io.servicetalk.transport.api.SslConfig: Get the list of usable CertificateCompressionAlgorithms to advertise.
certificateCompressionAlgorithms(CertificateCompressionAlgorithm...) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Sets the certificate compression algorithms to advertise if the feature is supported at runtime.
certificateCompressionAlgorithms(List<CertificateCompressionAlgorithm>) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Sets the certificate compression algorithms to advertise if the feature is supported at runtime.
CertificateCompressionAlgorithms - Class in io.servicetalk.transport.api: A factory to create Certificate Compression Algorithms.
CertificateCompressionException - Exception in io.servicetalk.transport.api: When thrown contains information about a failure during TLS certificate compression.
CertificateCompressionException(String) - Constructor for exception io.servicetalk.transport.api.CertificateCompressionException: Create a new CertificateCompressionException with just a message.
CertificateCompressionException(String, Throwable) - Constructor for exception io.servicetalk.transport.api.CertificateCompressionException: Create a new CertificateCompressionException with message and cause.
changePostToGet(boolean) - Method in class io.servicetalk.http.api.RedirectConfigBuilder: Enforces change of the request method from POST to GET for subsequent requests for 301 (Moved Permanently) and 302 (Found) status codes.
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
CHANNEL_CLOSED_INBOUND - Enum constant in enum class io.servicetalk.transport.netty.internal.CloseHandler.CloseEvent: Inbound SocketChannel shutdown observed.
CHANNEL_CLOSED_OUTBOUND - Enum constant in enum class io.servicetalk.transport.netty.internal.CloseHandler.CloseEvent: Outbound SocketChannel shutdown observed.
channelClosed(Throwable) - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
ChannelCloseUtils - Class in io.servicetalk.transport.netty.internal: Utilities to handle Channel closure and its reason.
channelError(Channel) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils: Returns an error associated with the passed Channel.
channelExecutionContext(Channel, ExecutionContext<ES>) - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextUtils: Utility that maps Channel.eventLoop() into IoExecutor and caches the result for future mappings to reduce allocations.
channelInactive(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
ChannelInitializer - Interface in io.servicetalk.transport.netty.internal: Configures a Channel.
channelOutboundClosed() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
channelRead(ChannelHandlerContext, Object) - Method in class io.servicetalk.transport.netty.internal.BufferHandler: Deprecated.
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.
channelWritable() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
CharSequences - Class in io.servicetalk.buffer.api: 8-bit ASCII strings factory and basic utilities helper.
CHARSET - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "charset"
CharsetUtils - Class in io.servicetalk.utils.internal: Charset utilities.
check() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
check() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
check(GrpcClientMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingHealthClient: If the requested service is unknown, the call will fail with status NOT_FOUND.
check(GrpcClientMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.HealthClient: If the requested service is unknown, the call will fail with status NOT_FOUND.
check(GrpcExecutionStrategy, Health.CheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
check(GrpcServiceContext, HealthCheckRequest) - Method in class io.servicetalk.grpc.health.DefaultHealthService
check(GrpcServiceContext, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingCheckRpc: If the requested service is unknown, the call will fail with status NOT_FOUND.
check(GrpcServiceContext, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.CheckRpc: If the requested service is unknown, the call will fail with status NOT_FOUND.
check(Health.CheckMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingHealthClient: Deprecated.
Use Health.BlockingHealthClient.check(GrpcClientMetadata,HealthCheckRequest).
check(Health.CheckMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.HealthClient: Deprecated.
Use Health.HealthClient.check(GrpcClientMetadata,HealthCheckRequest).
check(Health.CheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
check(HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingHealthClient: If the requested service is unknown, the call will fail with status NOT_FOUND.
check(HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.HealthClient: If the requested service is unknown, the call will fail with status NOT_FOUND.
checkBlocking(GrpcExecutionStrategy, Health.BlockingCheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
checkBlocking(Health.BlockingCheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
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.
CheckMetadata(ContentCodec) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata: Deprecated.
CheckMetadata(GrpcExecutionStrategy) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata: Deprecated.
CheckMetadata(GrpcExecutionStrategy, ContentCodec) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata: Deprecated.
CheckMetadata(GrpcExecutionStrategy, ContentCodec, Duration) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata: Deprecated.
CheckMetadata(Duration) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata: Deprecated.
CHUNKED - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "chunked"
ciphers() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
ciphers() - Method in interface io.servicetalk.transport.api.SslConfig: Get the cipher suites to enable, in the order of preference.
ciphers(String...) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Set the cipher suites to enable, in the order of preference.
ciphers(List<String>) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Set 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 entries from the current context.
clear() - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
clear() - Method in interface io.servicetalk.context.api.ContextMap: Clear the contents of this ContextMap.
clear() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
clear() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
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
clearField(Descriptors.FieldDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
clearField(Descriptors.FieldDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
clearOneof(Descriptors.OneofDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
clearOneof(Descriptors.OneofDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
clearService() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder: string service = 1;
clearStatus() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder: .grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;
clearStatus(String) - Method in class io.servicetalk.grpc.health.DefaultHealthService: Clears the health status record of a service.
clearThreadLocal() - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextUtils
CLIENT_ERROR_4XX - Enum constant in enum class io.servicetalk.http.api.HttpResponseStatus.StatusClass: Client Error 4xx.
clientAuthMode() - Method in class io.servicetalk.transport.api.DelegatingServerSslConfig
clientAuthMode() - Method in interface io.servicetalk.transport.api.ServerSslConfig: Get the client authentication mode.
clientAuthMode(SslClientAuthMode) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder: Set the SslClientAuthMode which determines how client authentication should be done.
ClientFactory() - Constructor for class io.servicetalk.health.v1.Health.ClientFactory
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: Deprecated.
There is no use of this interface in our codebase, it will be removed in the future releases. If you depend on it, consider replicating a similar interface in your codebase.
ClientSslConfig - Interface in io.servicetalk.transport.api: Specifies the configuration for client side TLS/SSL.
ClientSslConfigBuilder - Class in io.servicetalk.transport.api: Default builder for ClientSslConfig objects.
ClientSslConfigBuilder() - Constructor for class io.servicetalk.transport.api.ClientSslConfigBuilder: Create a new instance using this JVM's TrustManagerFactory.getDefaultAlgorithm() and default TrustManagerFactory.
ClientSslConfigBuilder(Supplier<InputStream>) - Constructor for class io.servicetalk.transport.api.ClientSslConfigBuilder: Create a new instance using trustCertChainSupplier to verify trusted servers.
ClientSslConfigBuilder(TrustManagerFactory) - Constructor for class io.servicetalk.transport.api.ClientSslConfigBuilder: Create a new instance using tmf to verify trusted servers.
clone() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
clone() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
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 class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
close() - Method in interface io.servicetalk.http.api.HttpClient
close() - Method in interface io.servicetalk.http.api.HttpConnection
close() - Method in interface io.servicetalk.http.api.StreamingHttpClient
close() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
close() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
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: Deprecated.

Disposes this StreamingDeserializer.
close() - Method in interface io.servicetalk.transport.api.ServerContext
close(ChannelHandlerContext, Throwable) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils: Close the passed ChannelHandlerContext due to the observed error.
close(Channel, Throwable) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils: Close the passed Channel due to the observed error.
close(Throwable) - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
close(Throwable) - Method in interface io.servicetalk.oio.api.PayloadWriter: This method shares the same characteristics as Closeable.close() but propagates cause to downstream consumer instead of propagating "successful" completion.
CLOSE - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "close"
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.
closeAndReThrow(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils: Call AutoCloseable.close() and re-throw any exception.
closeAndReThrowIoException(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils: Call AutoCloseable.close() and re-throw any exceptions as a IOException.
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.
closeAndReThrowUnchecked(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils: Deprecated.
Use AutoClosableUtils.closeAndReThrow(AutoCloseable).
closeAsync() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
closeAsync() - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup: Deprecated.
closeAsync() - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap: Deprecated.
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 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.DelegatingFilterableStreamingHttpLoadBalancedConnection
closeAsync() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
closeAsync() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
closeAsync() - Method in interface io.servicetalk.http.api.HttpService: Closes this HttpService asynchronously.
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.StreamingHttpServiceToOffloadedStreamingHttpService
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: Deprecated.
closeAsync() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
closeAsync() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
closeAsync() - Method in interface io.servicetalk.transport.api.EarlyConnectionAcceptor
closeAsync() - Method in interface io.servicetalk.transport.api.LateConnectionAcceptor
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: Deprecated.
closeAsyncGracefully() - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap: Deprecated.
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() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
closeAsyncGracefully() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
closeAsyncGracefully() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
closeAsyncGracefully() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
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.http.api.StreamingHttpServiceToOffloadedStreamingHttpService
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
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().
closeAsyncGracefullyNoOffload() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
closeAsyncNoOffload() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
ClosedPartitionException - Exception in io.servicetalk.client.api.partition: Deprecated.
We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.
ClosedPartitionException(PartitionAttributes, String) - Constructor for exception io.servicetalk.client.api.partition.ClosedPartitionException: Deprecated.

Create a new instance.
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 class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
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
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().
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 Class 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.
CloseHandler.DiscardFurtherInboundEvent - Class in io.servicetalk.transport.netty.internal: Netty UserEvent to indicate the further inbound data should be discarded.
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.
code() - Method in class io.servicetalk.grpc.api.GrpcStatus: Returns the status code.
code() - Method in class io.servicetalk.http.api.Http2ErrorCode: Get the decimal value of the error 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() - Method in exception io.servicetalk.encoding.api.CodecDecodingException: Deprecated.

Returns the codec in use when this exception occurred.
codec() - Method in exception io.servicetalk.encoding.api.CodecEncodingException: Deprecated.

Returns the codec in use when this exception occurred.
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.
Codec - Enum Class in io.servicetalk.opentracing.zipkin.publisher.reporter: Zipkin data formats for reporting of Spans.
CodecDecodingException - Exception in io.servicetalk.encoding.api: Deprecated.
Use BufferEncodingException.
CodecDecodingException(ContentCodec, String) - Constructor for exception io.servicetalk.encoding.api.CodecDecodingException: Deprecated.

New instance.
CodecDecodingException(ContentCodec, String, Throwable) - Constructor for exception io.servicetalk.encoding.api.CodecDecodingException: Deprecated.

New instance.
CodecEncodingException - Exception in io.servicetalk.encoding.api: Deprecated.
Use BufferEncodingException.
CodecEncodingException(ContentCodec, String) - Constructor for exception io.servicetalk.encoding.api.CodecEncodingException: Deprecated.

New instance.
CodecEncodingException(ContentCodec, String, Throwable) - Constructor for exception io.servicetalk.encoding.api.CodecEncodingException: Deprecated.

New instance.
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(int, Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single: Asynchronously collects results of the passed Singles 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>>) - 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(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.
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>>) - 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(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.
combine(GrpcLifecycleObserver, GrpcLifecycleObserver) - Static method in class io.servicetalk.grpc.utils.GrpcLifecycleObservers: Combines multiple GrpcLifecycleObservers into a single GrpcLifecycleObserver.
combine(GrpcLifecycleObserver, GrpcLifecycleObserver, GrpcLifecycleObserver...) - Static method in class io.servicetalk.grpc.utils.GrpcLifecycleObservers: Combines multiple GrpcLifecycleObservers into a single GrpcLifecycleObserver.
combine(HttpLifecycleObserver, HttpLifecycleObserver) - Static method in class io.servicetalk.http.utils.HttpLifecycleObservers: Combines multiple HttpLifecycleObservers into a single HttpLifecycleObserver.
combine(HttpLifecycleObserver, HttpLifecycleObserver, HttpLifecycleObserver...) - Static method in class io.servicetalk.http.utils.HttpLifecycleObservers: Combines multiple HttpLifecycleObservers into a single HttpLifecycleObserver.
combine(TransportObserver...) - Static method in class io.servicetalk.transport.api.TransportObservers: Combines multiple TransportObservers into a single TransportObserver.
combine(Object, Object) - Static method in class io.servicetalk.utils.internal.ThrowableUtils: Combine two potential Throwables into one.
compareTo(PartitionAttributes.Key) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key: Deprecated.
compareTo(HttpProtocolVersion) - Method in class io.servicetalk.http.api.HttpProtocolVersion
compareTo(HttpRequestMethod) - Method in class io.servicetalk.http.api.HttpRequestMethod
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.
CompletableFirstStep - Interface in io.servicetalk.concurrent.api.test: Provides the ability to express expectations for the first step in a Subscriber's lifecycle.
CompletableLastStep - Interface in io.servicetalk.concurrent.api.test: Provides the ability to express expectations for the terminal signals (e.g.
CompletableOperator - Interface in io.servicetalk.concurrent.api: An operator contract for a Completable.
completableOrError() - Method in class io.servicetalk.concurrent.api.Publisher: Converts this Publisher to 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
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"
COMPRESSION_ERROR - Static variable in class io.servicetalk.http.api.Http2ErrorCode: COMPRESSION_ERROR.
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.
computeIfAbsent(ContextMap.Key<T>, Function<ContextMap.Key<T>, T>) - Static method in class io.servicetalk.concurrent.api.AsyncContext: Convenience method to compute a new entry for the current context if this map does not already contain this key or is mapped to null.
computeIfAbsent(ContextMap.Key<T>, Function<ContextMap.Key<T>, T>) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
computeIfAbsent(ContextMap.Key<T>, Function<ContextMap.Key<T>, T>) - Method in interface io.servicetalk.context.api.ContextMap: Computes a new entry for this ContextMap if this map does not already contain this key or is mapped to null.
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(Completable) - Method in class io.servicetalk.concurrent.api.Publisher: Listens for completion of next Completable after this Publisher terminates successfully.
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(Completable...) - Method in class io.servicetalk.concurrent.api.Completable: Once this Completable is terminated successfully, subscribe to each Completable in nexts in a sequential fashion after termination, and the final terminal signals is propagated to the returned Completable.
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(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.
concat(Publisher<? extends T>, boolean) - Method in class io.servicetalk.concurrent.api.Single: Deprecated.
Use Single.concat(Publisher) or Single.concatDeferSubscribe(Publisher) instead.
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(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(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.
concatDeferSubscribe(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Single: This method is like Single.concat(Publisher) subscribe to the next Publisher will be deferred until demand is received (at least 2 items requested).
concatPropagateCancel(Completable) - Method in class io.servicetalk.concurrent.api.Publisher: This method is like Publisher.concat(Completable) except next will be subscribed to and cancelled if this Publisher is cancelled or terminates with PublisherSource.Subscriber.onError(Throwable).
concatPropagateCancel(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Single: This method is like Single.concat(Publisher) except next will be subscribed to and cancelled if this Publisher is cancelled or terminates with SingleSource.Subscriber.onError(Throwable).
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: Deprecated.
This internal class will be removed in the future releases without a replacement. If you depend on it, consider copying into your codebase.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T>) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber: Deprecated.

Create a new instance.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T>, boolean) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber: Deprecated.

Create a new instance.
ConcurrentUtils - Class in io.servicetalk.concurrent.internal: Utilities which can be used for concurrency.
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.data.protobuf.jersey.config.ServiceTalkProtobufSerializerAutoDiscoverable
configure(FeatureContext) - Method in class io.servicetalk.data.protobuf.jersey.ServiceTalkProtobufSerializerFeature
configure(FeatureContext) - Method in class io.servicetalk.http.router.jersey.config.ServiceTalkAutoDiscoverable
configure(FeatureContext) - Method in class io.servicetalk.http.router.jersey.ServiceTalkFeature
configureForPartition(PartitionAttributes, SingleAddressHttpClientBuilder<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator: Deprecated.

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() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.CONFLICT response.
CONFLICT - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 409 Conflict
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 class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
connect(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory: Create a new HttpRequestMethod.CONNECT request.
connect(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory: Create a new HttpRequestMethod.CONNECT request.
connect(SocketAddress, Object, ReadOnlyTcpClientConfig, boolean, ExecutionContext<?>, BiFunction<Channel, ConnectionObserver, Single<? extends C>>, TransportObserver) - Static method in class io.servicetalk.tcp.netty.internal.TcpConnector: Connects to the passed resolvedRemoteAddress address, resolving the address, if required.
CONNECT - Static variable in class io.servicetalk.http.api.HttpRequestMethod: HTTP CONNECT method.
CONNECT_ERROR - Static variable in class io.servicetalk.http.api.Http2ErrorCode: CONNECT_ERROR.
CONNECT_TIMEOUT - Static variable in class io.servicetalk.transport.api.ServiceTalkSocketOptions: 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
ConnectAndHttpExecutionStrategy - Class in io.servicetalk.http.api: Combines a ConnectExecutionStrategy and an HttpExecutionStrategy.
ConnectAndHttpExecutionStrategy(HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
ConnectAndHttpExecutionStrategy(ConnectExecutionStrategy) - Constructor for class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
ConnectAndHttpExecutionStrategy(ConnectExecutionStrategy, HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
ConnectExecutionStrategy - Interface in io.servicetalk.transport.api: An execution strategy for creating or accepting connections.
CONNECTION - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "connection"
ConnectionAcceptor - Interface in io.servicetalk.transport.api: Deprecated.
use LateConnectionAcceptor instead.
ConnectionAcceptorFactory - Interface in io.servicetalk.transport.api: Deprecated.
use LateConnectionAcceptor instead.
connectionClosed() - Method in interface io.servicetalk.transport.api.ConnectionObserver: Callback when the connection is closed.
connectionClosed() - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
connectionClosed(Throwable) - Method in interface io.servicetalk.transport.api.ConnectionObserver: Callback when the connection is closed due to an error.
connectionClosed(Throwable) - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
connectionContext() - Method in interface io.servicetalk.http.api.BlockingHttpConnection: Get the HttpConnectionContext.
connectionContext() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection: Get the HttpConnectionContext.
connectionContext() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
connectionContext() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpConnection: Get the HttpConnectionContext.
connectionContext() - Method in interface io.servicetalk.http.api.HttpConnection: Get the HttpConnectionContext.
connectionContext() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
connectionContext() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
ConnectionContext - Interface in io.servicetalk.transport.api: A context for a connection.
connectionEstablished(ConnectionInfo) - Method in interface io.servicetalk.transport.api.ConnectionObserver: Callback when a non-multiplexed connection is established and ready.
connectionEstablished(ConnectionInfo) - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
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.
ConnectionInfo - Interface in io.servicetalk.transport.api: Provides information about a connection.
ConnectionInfo.Protocol - Interface in io.servicetalk.transport.api: Provides information about the network protocol.
ConnectionLimitReachedException - Exception in io.servicetalk.client.api: Thrown when the number of connections reached their limit for a given resource (i.e.
ConnectionLimitReachedException(String) - Constructor for exception io.servicetalk.client.api.ConnectionLimitReachedException: Creates a new instance.
ConnectionObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into events associated with a network connection.
ConnectionObserver.DataObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into read and write events related to data flow.
ConnectionObserver.MultiplexedObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into new streams created by a multiplexed connection.
ConnectionObserver.ReadObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into read events.
ConnectionObserver.SecurityHandshakeObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into security handshake events.
ConnectionObserver.StreamObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into stream events.
ConnectionObserver.WriteObserver - Interface in io.servicetalk.transport.api: An observer interface that provides visibility into write events.
ConnectionObserverInitializer - Class in io.servicetalk.transport.netty.internal: A ChannelInitializer that registers a ConnectionObserver for all channels.
ConnectionObserverInitializer(ConnectionObserver, boolean, boolean) - Constructor for class io.servicetalk.transport.netty.internal.ConnectionObserverInitializer: Creates a new instance.
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.
connectionWritabilityChanged(boolean) - Method in interface io.servicetalk.transport.api.ConnectionObserver: Callback when a writable state of the connection changes.
connectionWritabilityChanged(boolean) - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
connectStrategy() - Method in class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy: Returns the ConnectExecutionStrategy portion of this strategy.
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.
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.
consolidateCacheSize(int) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Deprecated.
consolidateCacheSize(int) - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
consolidateCacheSize(int) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder: Set the maximum size of the cache that is used to consolidate concurrent lookups for different hostnames.
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() - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer: Consumes the termination of the holder.
consumeTerminal(Throwable) - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer: Consumes the Throwable that terminated the holder.
contains(int) - Method in enum class io.servicetalk.http.api.HttpResponseStatus.StatusClass: Determine if code falls into this HttpResponseStatus.StatusClass.
contains(PartitionAttributes.Key<T>) - Method in interface io.servicetalk.client.api.partition.PartitionAttributes: Deprecated.

Determine if there is a value associated with key.
contains(ContextMap.Key<T>, T) - Static method in class io.servicetalk.concurrent.api.AsyncContext: Convenience method to determine if this context contains an entry matching the passed key and value.
contains(ContextMap.Key<T>, T) - Method in interface io.servicetalk.context.api.ContextMap: Determine if this ContextMap contains an entry matching the passed key and value.
contains(HttpResponseStatus) - Method in enum class io.servicetalk.http.api.HttpResponseStatus.StatusClass: Determine if status code falls into this HttpResponseStatus.StatusClass.
contains(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 class io.servicetalk.http.api.EmptyHttpHeaders
contains(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Returns true if a header with the name and value exists, false otherwise.
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(ContextMap.Key<?>) - Static method in class io.servicetalk.concurrent.api.AsyncContext: Convenience method to determine if the current context contains an entry corresponding to the key.
containsKey(ContextMap.Key<?>) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
containsKey(ContextMap.Key<?>) - Method in interface io.servicetalk.context.api.ContextMap: Determine if this ContextMap contains an entry corresponding to the key.
containsKey(String) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
containsKey(String) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
containsValue(Object) - Static method in class io.servicetalk.concurrent.api.AsyncContext: Convenience method to determine if the current context contains an entry with the specified value.
containsValue(Object) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
containsValue(Object) - Method in interface io.servicetalk.context.api.ContextMap: Determine if this ContextMap contains an entry with the specified value.
content() - Method in interface io.servicetalk.buffer.api.BufferHolder: Deprecated.

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"
ContentCodec - Interface in io.servicetalk.encoding.api: Deprecated.
Use BufferEncoder and BufferDecoder.
ContentCodecToBufferDecoder - Class in io.servicetalk.encoding.api.internal: Deprecated.
Use BufferDecoder. This type will be removed along with ContentCodec.
ContentCodecToBufferDecoder(ContentCodec) - Constructor for class io.servicetalk.encoding.api.internal.ContentCodecToBufferDecoder: Deprecated.

Create a new instance.
ContentCodecToBufferEncoder - Class in io.servicetalk.encoding.api.internal: Deprecated.
Use BufferEncoder. This type will be removed along with ContentCodec.
ContentCodecToBufferEncoder(ContentCodec) - Constructor for class io.servicetalk.encoding.api.internal.ContentCodecToBufferEncoder: Deprecated.

Create a new instance.
ContentCodingHttpRequesterFilter - Class in io.servicetalk.http.api: Deprecated.
Use ContentEncodingHttpRequesterFilter.
ContentCodingHttpRequesterFilter(List<ContentCodec>) - Constructor for class io.servicetalk.http.api.ContentCodingHttpRequesterFilter: Deprecated.

Enable support of the provided encodings for requests and responses.
ContentCodingHttpServiceFilter - Class in io.servicetalk.http.api: Deprecated.
Use ContentEncodingHttpServiceFilter.
ContentCodingHttpServiceFilter(List<ContentCodec>) - Constructor for class io.servicetalk.http.api.ContentCodingHttpServiceFilter: Deprecated.

Enable support of the provided encodings for this server's responses.
ContentCodingHttpServiceFilter(List<ContentCodec>, List<ContentCodec>) - Constructor for class io.servicetalk.http.api.ContentCodingHttpServiceFilter: Deprecated.

Enable support of the provided encodings for both client requests and server responses.
ContentCodings - Class in io.servicetalk.encoding.netty: Deprecated.
Use NettyCompression and NettyBufferEncoders.
contentEncoding() - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Get the BufferEncoder to use for this request.
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.HttpRequest
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Set the BufferEncoder to use for this request.
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
ContentEncodingHttpRequesterFilter - Class in io.servicetalk.http.api: A StreamingHttpClientFilter that adds encoding / decoding functionality for requests and responses respectively, as these are specified by the spec Content-Encoding.
ContentEncodingHttpRequesterFilter(BufferDecoderGroup) - Constructor for class io.servicetalk.http.api.ContentEncodingHttpRequesterFilter: Create a new instance and specify the supported decompression (advertised in HttpHeaderNames.ACCEPT_ENCODING).
ContentEncodingHttpServiceFilter - Class in io.servicetalk.http.api: A StreamingHttpService that adds encoding / decoding functionality for responses and requests respectively, as these are specified by the spec Content-Encoding.
ContentEncodingHttpServiceFilter(List<BufferEncoder>) - Constructor for class io.servicetalk.http.api.ContentEncodingHttpServiceFilter: Create a new instance and specify the supported compression (matched against HttpHeaderNames.ACCEPT_ENCODING).
ContentEncodingHttpServiceFilter(List<BufferEncoder>, BufferDecoderGroup) - Constructor for class io.servicetalk.http.api.ContentEncodingHttpServiceFilter: Create a new instance and specify the supported decompression (matched against HttpHeaderNames.CONTENT_ENCODING) and compression (matched against HttpHeaderNames.ACCEPT_ENCODING).
contentEquals(CharSequence, CharSequence) - Static method in class io.servicetalk.buffer.api.CharSequences: Returns true if the content of both CharSequence's are equals.
contentEqualsIgnoreCase(CharSequence, CharSequence) - Static method in class io.servicetalk.buffer.api.CharSequences: Perform a case-insensitive comparison of two CharSequences.
contentType() - Method in interface io.servicetalk.grpc.api.SerializerDescriptor: Get the suffix to application/grpc which described the Content-Type for the serialization.
context() - Static method in class io.servicetalk.concurrent.api.AsyncContext: Get the current ContextMap.
context() - Method in interface io.servicetalk.context.api.ContextMapHolder: Get the current ContextMap.
context() - Method in interface io.servicetalk.grpc.api.BlockingStreamingGrpcServerResponse: A response context that will be translated into HttpMetaData.context().
context() - Method in interface io.servicetalk.http.api.HttpMetaData: A context associated with this HttpMetaData.
context() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpan
context(ContextMap) - Method in interface io.servicetalk.context.api.ContextMapHolder: Set the ContextMap.
context(ContextMap) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
context(ContextMap) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
context(ContextMap) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpMetaData: Sets a context for this HttpMetaData.
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpRequest
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpResponse
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
context(ContextMap) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
context(ContextMap) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
ContextFilterSuccessful - Class in io.servicetalk.transport.netty.internal: Netty pipeline event that represents the successful completion of the ConnectionAcceptor.
ContextMap - Interface in io.servicetalk.context.api: The key-value entry map for different types of the value, defined by the ContextMap.Key.
ContextMap.Key<T> - Class in io.servicetalk.context.api: A key identifies a specific object in a ContextMap.
ContextMapHolder - Interface in io.servicetalk.context.api: Interface for getting and setting a ContextMap.
ContextMapUtils - Class in io.servicetalk.concurrent.internal: Shared utilities for ContextMap.
contextResolverFor(ObjectMapper) - Static method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature: Deprecated.
Use ServiceTalkJacksonSerializerFeature.newContextResolver(ObjectMapper).
contextResolverFor(JacksonSerializationProvider) - Static method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature: Deprecated.
Use ServiceTalkJacksonSerializerFeature.newContextResolver(JacksonSerializerFactory).
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.
continueWriting() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
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() - Method in class io.servicetalk.buffer.api.EmptyBuffer
copy() - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
copy() - Method in interface io.servicetalk.context.api.ContextMap: Create an isolated copy of the current map.
copy() - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Deprecated.

Creates a deep copy of this StrategyInfluencerChainBuilder.
copy(int, int) - Method in interface io.servicetalk.buffer.api.Buffer: Returns a copy of this buffer's sub-region.
copy(int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
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.DelegatingConnectionFactoryFilter
create(ConnectionFactory<ResolvedAddress, C>) - Method in class io.servicetalk.client.api.LimitingConnectionFactoryFilter
create(ConnectionFactory<ResolvedAddress, C>) - Method in class io.servicetalk.client.api.TransportObserverConnectionFactoryFilter
create(Completable) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers: Creates a new CompletableFirstStep.
create(Publisher<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers: Creates a new PublisherFirstStep.
create(Single<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers: Creates a new SingleFirstStep.
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.api.ContentCodingHttpRequesterFilter: Deprecated.
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.api.ContentEncodingHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory: Creates a StreamingHttpClientFilter using the provided StreamingHttpClientFilter.
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.netty.HttpLifecycleObserverRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.EnforceSequentialModeRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.HostHeaderHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.PayloadSizeLimitingHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.RequestTargetEncoderHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryHttpRequestFilter
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.api.ContentCodingHttpRequesterFilter: Deprecated.
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.api.ContentEncodingHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in interface io.servicetalk.http.api.StreamingHttpConnectionFilterFactory: Create a StreamingHttpConnectionFilter using the provided FilterableStreamingHttpConnection.
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.netty.HttpLifecycleObserverRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.EnforceSequentialModeRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.HostHeaderHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.IdleTimeoutConnectionFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.JavaNetSoTimeoutHttpConnectionFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.PayloadSizeLimitingHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.RequestTargetEncoderHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryHttpRequestFilter
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
create(StreamingHttpService) - Method in class io.servicetalk.grpc.api.GrpcExceptionMapperServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.api.ContentCodingHttpServiceFilter: Deprecated.
create(StreamingHttpService) - Method in class io.servicetalk.http.api.ContentEncodingHttpServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.api.HttpExceptionMapperServiceFilter
create(StreamingHttpService) - Method in interface io.servicetalk.http.api.StreamingHttpServiceFilterFactory: Create a StreamingHttpServiceFilter using the provided StreamingHttpService.
create(StreamingHttpService) - Method in class io.servicetalk.http.netty.HttpLifecycleObserverServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.PayloadSizeLimitingHttpServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.RequestTargetDecoderHttpServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.RequestTargetEncoderHttpServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.TimeoutHttpServiceFilter
create(StreamingHttpService) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryHttpServerFilter
create(StreamingHttpService) - Method in class io.servicetalk.opentracing.http.TracingHttpServiceFilter
create(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory: Deprecated.

Create a ConnectionAcceptor using the provided ConnectionAcceptor.
create(Service) - Method in interface io.servicetalk.grpc.api.GrpcServiceFilterFactory: Deprecated.

Create a GrpcServiceFilterFactory using the provided GrpcServiceFilterFactory.
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() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.CREATED response.
CREATED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 201 Created
createForSource(CompletableSource) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers: Creates a new CompletableFirstStep.
createForSource(PublisherSource<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers: Creates a new PublisherFirstStep.
createForSource(SingleSource<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers: Creates a new SingleFirstStep.
createIoExecutor() - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors: Create a new NettyIoExecutor 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.
createIoExecutor(int) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors: Create a new NettyIoExecutor.
createIoExecutor(int) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors: Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(int, IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors: Create a new NettyIoExecutor.
createIoExecutor(int, IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors: Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(int, String) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors: Create a new NettyIoExecutor.
createIoExecutor(int, String) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors: Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors: Create a new NettyIoExecutor with the default number of ioThreads.
createIoExecutor(IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors: Creates a new IoExecutor with the default number of ioThreads.
createIoExecutor(String) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors: Create a new NettyIoExecutor with the default number of ioThreads.
createIoExecutor(String) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors: Creates a new IoExecutor with the default number of ioThreads.
cumulationReset() - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder: Resets cumulation.
currentStrategy() - Method in class io.servicetalk.transport.netty.internal.FlushStrategyHolder: Returns the current value of the enclosed FlushStrategy.
currentThreadIsIoThread() - Static method in interface io.servicetalk.transport.api.IoThreadFactory.IoThread: Returns true if the current thread is an IoThreadFactory.IoThread otherwise {code false}.
currentTime(TimeUnit) - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
currentTime(TimeUnit) - Method in interface io.servicetalk.concurrent.Executor
currentTime(TimeUnit) - Method in interface io.servicetalk.concurrent.TimeSource: Returns the internal clock time in the specified unit.
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 Builder for creating custom HttpExecutionStrategy.

D

DATA_LOSS - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode

Data corruption.

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"

DEADLINE_EXCEEDED - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode

Deadline expired.

DeadlineUtils - Class in io.servicetalk.grpc.internal

Constants and utilities related to gRPC deadlines.

DEBUG - Enum constant in enum class io.servicetalk.logging.api.LogLevel

DEBUG log level.

decode(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder

Decode the from one ByteBuf to an other.

decode(Buffer, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec

Deprecated.

Take a Buffer and decode its contents resulting in a Buffer with the decoded content.

decode(Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec

Deprecated.

Take a Publisher of Buffer and encode its contents resulting in a Publisher of Buffer with the decoded contents.

decodeLast(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder

Is called one last time when the ChannelHandlerContext goes in-active.

decoder() - Method in interface io.servicetalk.encoding.api.BufferDecoder

Get the Deserializer to use for aggregated content.

decoder() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferDecoder

Deprecated.

decoders() - Method in interface io.servicetalk.encoding.api.BufferDecoderGroup

Get the supported BufferDecoder for this group.

decoders() - Method in class io.servicetalk.encoding.api.EmptyBufferDecoderGroup

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

The default prefix used for new thread names.

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.

DefaultContextMap - Class in io.servicetalk.concurrent.internal

Default implementation of ContextMap.

DefaultContextMap() - Constructor for class io.servicetalk.concurrent.internal.DefaultContextMap

Creates a new instance.

defaultContextSupplier - Variable in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder

DefaultDnsServiceDiscovererBuilder - Class in io.servicetalk.dns.discovery.netty

Deprecated.

this class will be made package-private in the future, rely on the DnsServiceDiscovererBuilder instead.

DefaultDnsServiceDiscovererBuilder() - Constructor for class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder

Deprecated.

use DnsServiceDiscoverers.builder(String) instead.

DefaultExecutionContext<ES extends ExecutionStrategy> - Class in io.servicetalk.transport.api

A default implementation of ExecutionContext.

DefaultExecutionContext(BufferAllocator, IoExecutor, Executor, ES) - Constructor for class io.servicetalk.transport.api.DefaultExecutionContext

Create a new instance.

DefaultFilterableStreamingHttpLoadBalancedConnection(FilterableStreamingHttpConnection, ReservableRequestConcurrencyController) - Constructor for class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection

Create a new instance without support for HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection.score().

DefaultFilterableStreamingHttpLoadBalancedConnection(FilterableStreamingHttpConnection, ReservableRequestConcurrencyController, ScoreSupplier) - Constructor for class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection

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() - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Creates a new instance with default characteristics and empty request/response contexts.

DefaultGrpcClientMetadata(BufferEncoder) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Creates a new instance.

DefaultGrpcClientMetadata(BufferEncoder, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Creates a new instance.

DefaultGrpcClientMetadata(DefaultGrpcClientMetadata) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Create a new instance, by copying an existing instance.

DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Create a new instance.

DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Create a new instance.

DefaultGrpcClientMetadata(String) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata().

DefaultGrpcClientMetadata(String, ContentCodec) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(BufferEncoder)

DefaultGrpcClientMetadata(String, ContentCodec, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(BufferEncoder, Duration).

DefaultGrpcClientMetadata(String, GrpcClientMetadata) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(DefaultGrpcClientMetadata).

DefaultGrpcClientMetadata(String, GrpcExecutionStrategy) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder).

DefaultGrpcClientMetadata(String, GrpcExecutionStrategy, ContentCodec) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder).

DefaultGrpcClientMetadata(String, GrpcExecutionStrategy, ContentCodec, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder, Duration).

DefaultGrpcClientMetadata(String, GrpcExecutionStrategy, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder, Duration).

DefaultGrpcClientMetadata(String, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

Use DefaultGrpcClientMetadata(BufferEncoder, Duration).

DefaultGrpcClientMetadata(String, Supplier<ContextMap>, Supplier<ContextMap>, GrpcExecutionStrategy, ContentCodec, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Deprecated.

DefaultGrpcClientMetadata(Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata

Create a new instance.

DefaultHealthService - Class in io.servicetalk.grpc.health

Implementation of Health.HealthService which targets gRPC health checking that provides accessors to set/clear status for arbitrary services.

DefaultHealthService() - Constructor for class io.servicetalk.grpc.health.DefaultHealthService

Create a new instance.

DefaultHealthService(Predicate<String>) - Constructor for class io.servicetalk.grpc.health.DefaultHealthService

Create 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, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory

Create an instance of the factory with the default array size hint.

DefaultHttpHeadersFactory(boolean, 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.

defaultHttpPort(int) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder

defaultHttpPort(int) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder

Configures the default port for the HTTP scheme if not explicitly provided as part of the HttpRequestMetaData.requestTarget().

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.

defaultHttpsPort(int) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder

defaultHttpsPort(int) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder

Configures the default port for the HTTPS scheme if not explicitly provided as part of the HttpRequestMetaData.requestTarget().

defaultInitializer() - Static method in interface io.servicetalk.transport.netty.internal.ChannelInitializer

Default ChannelInitializer.

DefaultInMemorySpanContext - Class in io.servicetalk.opentracing.inmemory

SpanContext object used by the DefaultInMemoryTracer.

DefaultInMemorySpanContext(String, String, String, Boolean) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemorySpanContext

Constructs an instance.

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.

DefaultNettyConnection<Read,Write> - Class in io.servicetalk.transport.netty.internal

Implementation of NettyConnection backed by a netty Channel.

DefaultNettyConnection.CancelWriteUserEvent - Class in io.servicetalk.transport.netty.internal

Netty UserEvent to signal cancellation of the write stream.

DefaultNettyConnection.ContinueUserEvent - Class in io.servicetalk.transport.netty.internal

Netty UserEvent to signal continuation.

DefaultPartitionAttributesBuilder - Class in io.servicetalk.client.api.internal.partition

Deprecated.

We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.

DefaultPartitionAttributesBuilder(int) - Constructor for class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder

Deprecated.

Create a new instance.

DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api.internal

Deprecated.

DefaultPartitionedClientGroup(Function<PartitionAttributes, Client>, Function<PartitionAttributes, Client>, DefaultPartitionedClientGroup.PartitionedClientFactory<U, R, Client>, PartitionMapFactory, Publisher<PartitionedServiceDiscovererEvent<R>>, int) - Constructor for class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup

Deprecated.

Creates a new instance.

DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> - Interface in io.servicetalk.client.api.internal

Deprecated.

DefaultRouteExecutionStrategyFactory<ES extends ExecutionStrategy> - Class in io.servicetalk.router.utils.internal

Implementation of RouteExecutionStrategyFactory that always throws IllegalArgumentException.

DefaultSerializer - Class in io.servicetalk.serialization.api

Deprecated.

Use implementations of following types:

DefaultSerializer(SerializationProvider) - Constructor for class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

New instance.

DefaultServiceDiscovererEvent<T> - Class in io.servicetalk.client.api

Default implementation of ServiceDiscovererEvent.

DefaultServiceDiscovererEvent(T, ServiceDiscovererEvent.Status) - Constructor for class io.servicetalk.client.api.DefaultServiceDiscovererEvent

Create a new instance.

DefaultServiceTalkThreadContextMap - Class in io.servicetalk.log4j2.mdc

Empty subclass to differentiate uses of MDC.

DefaultServiceTalkThreadContextMap() - Constructor for class io.servicetalk.log4j2.mdc.DefaultServiceTalkThreadContextMap

defaultStrategy() - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies

A special default GrpcExecutionStrategy that offloads all actions unless merged with another strategy that requires less offloading.

defaultStrategy() - Static method in class io.servicetalk.http.api.HttpExecutionStrategies

A special default HttpExecutionStrategy that provides safe default offloading of actions; the offloading used is unspecified and dependent upon the usage situation.

defaultStrategyFactory() - Static method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory

Returns default RouteExecutionStrategyFactory.

DefaultStreamingHttpRequestResponseFactory - Class in io.servicetalk.http.api

A default implementation for StreamingHttpRequestFactory and StreamingHttpResponseFactory.

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

Deprecated.

This method is not useful anymore and will be removed in future releases.

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(boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory

New instance.

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(String, boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory

New instance.

defaultTimeout(Duration) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder

defaultTimeout(Duration) - Method in class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder

defaultTimeout(Duration) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder

Set default timeout during which gRPC calls are expected to complete.

defaultTimeout(Duration) - Method in interface io.servicetalk.grpc.api.GrpcServerBuilder

Set a default timeout during which gRPC calls are expected to complete.

defaultTimeout(Duration, boolean) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder

defaultTimeout(Duration, boolean) - Method in class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder

defaultTimeout(Duration, boolean) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder

Set default timeout during which gRPC calls are expected to complete.

defaultTimeout(Duration, boolean) - Method in interface io.servicetalk.grpc.api.GrpcServerBuilder

Set a default timeout during which gRPC calls are expected to complete.

DefaultUserDataLoggerConfig - Class in io.servicetalk.logging.slf4j.internal

Default implementation of LoggerConfig.

DefaultUserDataLoggerConfig(String, LogLevel, BooleanSupplier) - Constructor for class io.servicetalk.logging.slf4j.internal.DefaultUserDataLoggerConfig

Create a 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.

deferredOnComplete() - Method in class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber

Deprecated.

Indicate that a ConcurrentTerminalSubscriber.onComplete() should be delivered after ConcurrentTerminalSubscriber.deliverDeferredTerminal() is later called.

deferredOnError(Throwable) - Method in class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber

Deprecated.

Indicate that a ConcurrentTerminalSubscriber.onError(Throwable) should be delivered after ConcurrentTerminalSubscriber.deliverDeferredTerminal() is later called.

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 method in class io.servicetalk.encoding.netty.ContentCodings

Deprecated.

Returns a DEFLATE based ZipContentCodecBuilder that allows building a customizable ContentCodec.

deflate() - Static method in class io.servicetalk.encoding.netty.NettyCompression

Returns a DEFLATE based ZipCompressionBuilder.

DEFLATE - Static variable in class io.servicetalk.http.api.HttpHeaderValues

"deflate"

deflateDefault() - Static method in class io.servicetalk.encoding.netty.ContentCodings

Deprecated.

Returns the default DEFLATE based ContentCodec.

deflateDefault() - Static method in class io.servicetalk.encoding.netty.NettyBufferEncoders

Get a default BufferEncoderDecoder for deflate encoding.

deflateDefault() - Static method in class io.servicetalk.encoding.netty.NettyCompression

Returns the default DEFLATE based SerializerDeserializer.

deflateDefaultStreaming() - Static method in class io.servicetalk.encoding.netty.NettyCompression

Returns the default DEFLATE based StreamingSerializerDeserializer.

delay() - Method in interface io.servicetalk.http.netty.RetryingHttpRequesterFilter.DelayedRetry

A constant delay to apply in milliseconds.

delayedCancellable(Cancellable) - Method in class io.servicetalk.concurrent.internal.DelayedCancellable

Set the delayed Cancellable.

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

delayedSubscription(PublisherSource.Subscription) - Method in class io.servicetalk.concurrent.internal.DelayedSubscription

Set the delayed PublisherSource.Subscription.

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

delegate() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory

Returns the ConnectionFactory delegate.

delegate() - Method in class io.servicetalk.client.api.DelegatingConnectionFactoryFilter

Returns the ConnectionFactoryFilter delegate.

delegate() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor

Returns the delegate Executor used.

delegate() - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder

Returns the DnsServiceDiscovererBuilder delegate.

delegate() - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder

Returns the GrpcClientBuilder delegate.

delegate() - Method in class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder

Returns the GrpcServerBuilder 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.DelegatingHttpExecutionContext

Get the HttpExecutionContext that this class delegates to.

delegate() - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder

Returns the HttpServerBuilder delegate.

delegate() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext

Returns the delegate HttpServiceContext.

delegate() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder

Returns the MultiAddressHttpClientBuilder delegate.

delegate() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder

Returns the PartitionedHttpClientBuilder delegate.

delegate() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder

Returns the SingleAddressHttpClientBuilder delegate.

delegate() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter

Get the FilterableReservedStreamingHttpConnection 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.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder

Returns the DelegatingRoundRobinLoadBalancerBuilder delegate.

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.api.DelegatingSslConfig

Get the DelegatingSslConfig to delegate to.

delegate() - Method in class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy

Returns the delegate FlushStrategy used.

DelegatingClientSslConfig - Class in io.servicetalk.transport.api

Wrap a ClientSslConfig and delegate all methods to it.

DelegatingClientSslConfig(ClientSslConfig) - Constructor for class io.servicetalk.transport.api.DelegatingClientSslConfig

Create a new instance.

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.

DelegatingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api

A ConnectionFactoryFilter that delegates all methods to another ConnectionFactoryFilter.

DelegatingConnectionFactoryFilter(ConnectionFactoryFilter<ResolvedAddress, C>) - Constructor for class io.servicetalk.client.api.DelegatingConnectionFactoryFilter

Create a new instance.

DelegatingDnsServiceDiscovererBuilder - Class in io.servicetalk.dns.discovery.netty

A DnsServiceDiscovererBuilder that delegates all methods to another DnsServiceDiscovererBuilder.

DelegatingDnsServiceDiscovererBuilder(DnsServiceDiscovererBuilder) - Constructor for class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder

Creates a new builder which delegates to the provided DnsServiceDiscovererBuilder.

DelegatingExecutionContext<ES extends ExecutionStrategy> - Class in io.servicetalk.transport.api

An ExecutionContext implementation that delegates all calls to a provided ExecutionContext.

DelegatingExecutionContext(ExecutionContext<? extends ES>) - 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.

DelegatingFilterableStreamingHttpLoadBalancedConnection - Class in io.servicetalk.http.api

Implementation of FilterableStreamingHttpLoadBalancedConnection that delegates all methods.

DelegatingFilterableStreamingHttpLoadBalancedConnection(FilterableStreamingHttpLoadBalancedConnection) - Constructor for class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection

Create a 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.

DelegatingGrpcClientBuilder<U,R> - Class in io.servicetalk.grpc.api

A GrpcClientBuilder that delegates all methods to another GrpcClientBuilder.

DelegatingGrpcClientBuilder(GrpcClientBuilder<U, R>) - Constructor for class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder

DelegatingGrpcServerBuilder - Class in io.servicetalk.grpc.api

A GrpcServerBuilder that delegates all methods to another GrpcServerBuilder.

DelegatingGrpcServerBuilder(GrpcServerBuilder) - Constructor for class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder

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.

DelegatingHttpServerBuilder - Class in io.servicetalk.http.api

A HttpServerBuilder that delegates all methods to another HttpServerBuilder.

DelegatingHttpServerBuilder(HttpServerBuilder) - Constructor for class io.servicetalk.http.api.DelegatingHttpServerBuilder

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.

DelegatingMultiAddressHttpClientBuilder<U,R> - Class in io.servicetalk.http.api

A MultiAddressHttpClientBuilder that delegates all methods to another MultiAddressHttpClientBuilder.

DelegatingMultiAddressHttpClientBuilder(MultiAddressHttpClientBuilder<U, R>) - Constructor for class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder

Create a new instance.

DelegatingPartitionedHttpClientBuilder<U,R> - Class in io.servicetalk.http.api

A PartitionedHttpClientBuilder that delegates all methods to another PartitionedHttpClientBuilder.

DelegatingPartitionedHttpClientBuilder(PartitionedHttpClientBuilder<U, R>) - Constructor for class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder

Create a new instance.

DelegatingRoundRobinLoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection> - Class in io.servicetalk.loadbalancer

A RoundRobinLoadBalancerBuilder that delegates all methods to another RoundRobinLoadBalancerBuilder.

DelegatingRoundRobinLoadBalancerBuilder(RoundRobinLoadBalancerBuilder<ResolvedAddress, C>) - Constructor for class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder

Creates a new builder which delegates to the provided RoundRobinLoadBalancerBuilder.

DelegatingServerSslConfig - Class in io.servicetalk.transport.api

Wrap a ServerSslConfig and delegate all methods to it.

DelegatingServerSslConfig(ServerSslConfig) - Constructor for class io.servicetalk.transport.api.DelegatingServerSslConfig

Create a new instance.

DelegatingSingleAddressHttpClientBuilder<U,R> - Class in io.servicetalk.http.api

A SingleAddressHttpClientBuilder that delegates all methods to another SingleAddressHttpClientBuilder.

DelegatingSingleAddressHttpClientBuilder(SingleAddressHttpClientBuilder<U, R>) - Constructor for class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder

Create a new instance.

DelegatingSslConfig<T extends SslConfig> - Class in io.servicetalk.transport.api

Wrap a SslConfig and delegate all methods to it.

DelegatingSslConfig(T) - Constructor for class io.servicetalk.transport.api.DelegatingSslConfig

Create a new instance.

delete(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory

Create a new HttpRequestMethod.DELETE request.

delete(String) - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection

delete(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory

Create a new HttpRequestMethod.DELETE request.

delete(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory

Create a new HttpRequestMethod.DELETE request.

DELETE - Static variable in class io.servicetalk.http.api.HttpRequestMethod

HTTP DELETE method.

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.

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.

deliverDeferredTerminal() - Method in class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber

Deprecated.

Try to deliver a terminal signal typically set by ConcurrentTerminalSubscriber.deferredOnComplete() or ConcurrentTerminalSubscriber.deferredOnError(Throwable).

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.

deliverErrorFromSource(PublisherSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils

Deliver a terminal error to a PublisherSource.Subscriber that has not yet had PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) called.

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.

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.

description() - Method in class io.servicetalk.grpc.api.GrpcStatus

Returns additional descriptions, can be null.

deserialize(Buffer) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer

Deprecated.

Use StreamingDeserializer that understands your protocol's framing.

deserialize(Buffer, BufferAllocator) - Method in interface io.servicetalk.serializer.api.Deserializer

Deserialize the contents from the Buffer parameter.

deserialize(Buffer, BufferAllocator) - Method in class io.servicetalk.serializer.utils.StringSerializer

deserialize(Buffer, BufferAllocator) - Method in class io.servicetalk.serializer.utils.ByteArraySerializer

deserialize(Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.serializer.api.StreamingDeserializer

Deserialize a Publisher of Buffer into a Publisher of StreamingDeserializer.

deserialize(Publisher<Buffer>, BufferAllocator) - Method in class io.servicetalk.serializer.utils.FixedLengthStreamingSerializer

deserialize(Publisher<Buffer>, BufferAllocator) - Method in class io.servicetalk.serializer.utils.VarIntLengthStreamingSerializer

deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer.deserialize(Publisher, BufferAllocator).

deserialize(Publisher<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserialize(Publisher<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer.deserialize(Publisher, BufferAllocator).

deserialize(BlockingIterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer

Deprecated.

Use StreamingDeserializer.deserialize(Iterable, BufferAllocator).

deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer.deserialize(Iterable, BufferAllocator).

deserialize(BlockingIterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserialize(BlockingIterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer.deserialize(Iterable, BufferAllocator).

deserialize(HttpHeaders, Buffer) - Method in interface io.servicetalk.http.api.HttpDeserializer

Deprecated.

Deserialize a single Object into a HttpDeserializer.

deserialize(HttpHeaders, BufferAllocator, Buffer) - Method in interface io.servicetalk.http.api.HttpDeserializer2

Deserialize a single Object into a HttpDeserializer2.

deserialize(HttpHeaders, Publisher<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer

Deprecated.

Deserialize a Publisher of Objects into a Publisher of type HttpDeserializer.

deserialize(HttpHeaders, Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.http.api.HttpStreamingDeserializer

Deserialize a Publisher of Objects into a Publisher of type HttpStreamingDeserializer.

deserialize(HttpHeaders, BlockingIterable<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer

Deprecated.

Deserialize a BlockingIterable of Objects into a BlockingIterable of type HttpDeserializer.

deserialize(HttpHeaders, BlockingIterable<Buffer>, BufferAllocator) - Method in interface io.servicetalk.http.api.HttpStreamingDeserializer

Deserialize a BlockingIterable of Objects into a BlockingIterable of type HttpStreamingDeserializer.

deserialize(Iterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer

Deprecated.

Use StreamingDeserializer.deserialize(Iterable, BufferAllocator).

deserialize(Iterable<Buffer>, BufferAllocator) - Method in interface io.servicetalk.serializer.api.StreamingDeserializer

Deserialize a Iterable of Buffer into a Iterable of StreamingDeserializer.

deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer.deserialize(Iterable, BufferAllocator).

deserialize(Iterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserialize(Iterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer.deserialize(Iterable, BufferAllocator).

deserializeAggregated(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserializeAggregated(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer that understands your protocol's framing.

deserializeAggregated(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserializeAggregated(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use StreamingDeserializer that understands your protocol's framing.

deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use Deserializer.

deserializeAggregatedSingle(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer

Deprecated.

deserializeAggregatedSingle(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer

Deprecated.

Use Deserializer.

Deserializer<T> - Interface in io.servicetalk.serializer.api

Deserialize objects from Buffer to Deserializer.

deserializerFor(ContentCodec, Class<T>) - Method in interface io.servicetalk.grpc.api.GrpcSerializationProvider

Deprecated.

Get a HttpDeserializer for a Class of type GrpcSerializationProvider.

deserializerFor(TypeHolder<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider

Deprecated.

Get a HttpDeserializer for a TypeHolder of type HttpSerializationProvider.

deserializerFor(Class<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider

Deprecated.

Get a HttpDeserializer for a Class of type HttpSerializationProvider.

detectBoundary(Object) - Method in interface io.servicetalk.transport.netty.internal.SplittingFlushStrategy.FlushBoundaryProvider

Deprecated.

Detect the SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for the passed itemWritten.

difference(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.

disableAllRetries() - Static method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter

Retrying filter that disables any form of retry behaviour.

disableAutoRetries() - Static method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter

Retrying filter that disables automatic retries for exceptions, but still waits until LoadBalancer becomes ready for the first time.

disabled() - Static method in class io.servicetalk.http.netty.H2KeepAlivePolicies

Returns a H2ProtocolConfig.KeepAlivePolicy that disables all keep alive behaviors.

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 ServiceDiscoverer associated with address.

discoveryCancelled() - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererObserver.DnsDiscoveryObserver

Notifies that the current DNS discovery got cancelled.

discoveryFailed(Throwable) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererObserver.DnsDiscoveryObserver

Notifies that the current DNS discovery failed.

distinct() - Method in class io.servicetalk.concurrent.api.Publisher

Only emits distinct signals observed by this Publisher.

dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder

Deprecated.

dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder

dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder

Sets the list of the protocol families of the address resolved.

DnsResolverAddressTypes - Enum Class 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

Deprecated.

dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder

dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder

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.

DnsServiceDiscovererBuilder - Interface in io.servicetalk.dns.discovery.netty

Builder for DNS ServiceDiscoverer which will attempt to resolve A, AAAA, CNAME, and SRV type queries.

DnsServiceDiscovererBuilderProvider - Interface in io.servicetalk.dns.discovery.netty

Provider for DnsServiceDiscovererBuilder.

DnsServiceDiscovererObserver - Interface in io.servicetalk.dns.discovery.netty

An observer that provides visibility into DNS ServiceDiscoverer built by DnsServiceDiscovererBuilder.

DnsServiceDiscovererObserver.DnsDiscoveryObserver - Interface in io.servicetalk.dns.discovery.netty

An observer that provides visibility into individual DNS discoveries.

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.

DnsServiceDiscoverers - Class in io.servicetalk.dns.discovery.netty

A factory to create DNS ServiceDiscoverers.

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.

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

Domain Matching.

DomainSocketAddress - Class in io.servicetalk.transport.api

An address which represents a socket belonging to the AF_UNIX socket family.

DomainSocketAddress(File) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress

Create a new instance.

DomainSocketAddress(String) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress

Create a new instance.

drainRequestPayloadBody(boolean) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder

drainRequestPayloadBody(boolean) - Method in interface io.servicetalk.http.api.HttpServerBuilder

Configure automatic consumption of request payload body when it is not consumed by the service.

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

Deprecated.

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.

DuplicateAttributeException - Exception in io.servicetalk.client.api.partition

Deprecated.

DuplicateAttributeException(PartitionAttributes.Key, String) - Constructor for exception io.servicetalk.client.api.partition.DuplicateAttributeException

Deprecated.

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.

DurationUtils - Class in io.servicetalk.utils.internal

Helper utilities for Duration.

E

EARLY_HINTS - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 103 Early Hints
EarlyConnectionAcceptor - Interface in io.servicetalk.transport.api: Allows to accept or reject connections early in the connection setup stage.
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.
effectiveHostAndPort() - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Get the host and port components of the effective request URI.
EIGHT_NINES - Static variable in class io.servicetalk.grpc.internal.DeadlineUtils: gRPC spec requires timeout value to be 8 or fewer ASCII integer digits.
ElementsAreNonnullByDefault - Annotation Interface 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.EmptySubscriptions: A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will throw on invalid demand.
EMPTY_SUBSCRIPTION_NO_THROW - Static variable in class io.servicetalk.concurrent.internal.EmptySubscriptions: A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will not throw on invalid demand.
emptyAsciiString() - Static method in class io.servicetalk.buffer.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.
EmptyBufferDecoderGroup - Class in io.servicetalk.encoding.api: A BufferDecoderGroup which is empty.
EmptyHttpHeaders - Class in io.servicetalk.http.api: HttpHeaders which are always empty and does not allow modification.
EmptySubscriptions - Class in io.servicetalk.concurrent.internal: Utility methods for PublisherSource.Subscriptions which don't deliver any data.
enableFrameLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder: Enables a logger for HTTP/2 frames.
enableMetrics() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions: Whether to enable operation metrics or not.
enableMetrics(boolean) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder: Whether to enable operation metrics or not.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Enables wire-logging for this server.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Enables wire-logging for connections created by this builder.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder: Enables wire-logging for UDP packets sent.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig: Enable wire-logging for all connections.
encode(Buffer, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec: Deprecated.

Take a Buffer and encode its contents resulting in a Buffer with the encoded contents.
encode(Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec: Deprecated.

Take a Publisher of Buffer and encode its contents resulting in a Publisher of Buffer with the encoded contents.
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.
encoder() - Method in interface io.servicetalk.encoding.api.BufferEncoder: Get the Serializer to use for aggregated content.
encoder() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferEncoder: Deprecated.
encoding() - Method in exception io.servicetalk.grpc.api.MessageEncodingException: Deprecated.

The name of the encoding used when the Exception was thrown.
encoding() - Method in interface io.servicetalk.http.api.HttpMetaData: Deprecated.
Use HttpRequestMetaData.contentEncoding() for requests and ContentEncodingHttpServiceFilter for responses. An example can be found here.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest: Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse: Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.HttpMetaData: Deprecated.
Use HttpRequestMetaData.contentEncoding(BufferEncoder) for requests and ContentEncodingHttpServiceFilter for responses. An example can be found here.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.HttpRequest: Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.HttpResponse
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.StreamingHttpRequest: Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.StreamingHttpResponse: Deprecated.
encodingFor(Collection<ContentCodec>, CharSequence) - Static method in class io.servicetalk.encoding.api.internal.HeaderUtils: Deprecated.
Use HeaderUtils.encodingForRaw(List, Function, CharSequence).
encodingForRaw(List<T>, Function<T, CharSequence>, CharSequence) - Static method in class io.servicetalk.encoding.api.internal.HeaderUtils: Get the first encoding that matches name from supportedEncoders.
encodingName() - Method in interface io.servicetalk.encoding.api.BufferDecoder: Get the name of the encoding.
encodingName() - Method in interface io.servicetalk.encoding.api.BufferEncoder: Get the name of the encoding.
encodingName() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferDecoder: Deprecated.
encodingName() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferEncoder: Deprecated.
End - Enum constant in enum class io.servicetalk.transport.netty.internal.SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary: Deprecated.
EnforceSequentialModeRequesterFilter - Class in io.servicetalk.http.utils: Enforces sequential behavior of the client, deferring return of the response until after the request payload body is sent.
ENHANCE_YOUR_CALM - Static variable in class io.servicetalk.http.api.Http2ErrorCode: ENHANCE_YOUR_CALM.
ensureNonNegative(Duration, String) - Static method in class io.servicetalk.utils.internal.DurationUtils: Ensures the duration is non-negative.
ensurePositive(Duration, String) - Static method in class io.servicetalk.utils.internal.DurationUtils: Ensures the duration is positive, excluding zero.
ensureType(ContextMap.Key<?>, Object) - Static method in class io.servicetalk.concurrent.internal.ContextMapUtils: Make sure that the value type matches with the ContextMap.Key.type().
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) - Method in class io.servicetalk.buffer.api.EmptyBuffer
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, 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(ContextMap, ContextMap) - Static method in class io.servicetalk.concurrent.internal.ContextMapUtils: Objects.equals(Object, Object) alternative for ContextMap.
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.buffer.api.EmptyBuffer
equals(Object) - Method in class io.servicetalk.client.api.DefaultGroupKey
equals(Object) - Method in class io.servicetalk.client.api.DefaultServiceDiscovererEvent
equals(Object) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key: Deprecated.
equals(Object) - Method in class io.servicetalk.client.api.ServiceDiscovererEvent.Status
equals(Object) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
equals(Object) - Method in class io.servicetalk.concurrent.internal.TerminalNotification
equals(Object) - Method in interface io.servicetalk.context.api.ContextMap: Determines if the specified object is equal to this ContextMap.
equals(Object) - Method in class io.servicetalk.grpc.api.GrpcStatus
equals(Object) - Method in class io.servicetalk.health.v1.HealthCheckRequest
equals(Object) - Method in class io.servicetalk.health.v1.HealthCheckResponse
equals(Object) - Method in class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
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.EmptyHttpHeaders
equals(Object) - Method in class io.servicetalk.http.api.Http2ErrorCode
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.logging.slf4j.internal.DefaultUserDataLoggerConfig
equals(Object) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions
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
equalsIgnoreCaseLower(char, char) - Static method in class io.servicetalk.buffer.api.CharSequences: Compare an unknown ascii character a with a known lowercase character lowerCaseChar in a case insensitive manner.
error(Throwable) - Static method in class io.servicetalk.concurrent.internal.TerminalNotification: Returns a TerminalNotification for cause.
ERROR - Enum constant in enum class io.servicetalk.logging.api.LogLevel: ERROR log level.
errorCode() - Method in exception io.servicetalk.http.api.Http2Exception: Get the error code which caused this exception.
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: Deprecated.
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: Deprecated.
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.
execute(Runnable) - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
execute(Runnable) - Method in interface io.servicetalk.concurrent.Executor: Executes the passed task as soon as possible.
execute(Runnable) - Method in interface io.servicetalk.transport.api.IoExecutor
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.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.GrpcServerContext
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.DelegatingFilterableStreamingHttpLoadBalancedConnection
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 class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
executionContext() - Method in interface io.servicetalk.http.api.HttpRequester: Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.http.api.HttpServerContext
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 interface io.servicetalk.transport.api.ConnectionInfo: Get the ExecutionContext for this ConnectionInfo.
executionContext() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
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
ExecutionContext<ES extends ExecutionStrategy> - Interface in io.servicetalk.transport.api: Context related to execution and allocation.
ExecutionContextBuilder<ES extends ExecutionStrategy> - Class in io.servicetalk.transport.netty.internal: A builder of ExecutionContext.
ExecutionContextBuilder() - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: New instance.
ExecutionContextBuilder(ExecutionContext<ES>) - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: New instance.
ExecutionContextBuilder(ExecutionContextBuilder<ES>) - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Copy constructor.
ExecutionContextUtils - Class in io.servicetalk.transport.netty.internal: Provides utilities around Executors, ExecutionContexts and how they interact with netty Channels.
executionStrategy() - Method in interface io.servicetalk.grpc.api.GrpcExecutionContext: Returns the GrpcExecutionStrategy associated with this context.
executionStrategy() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
executionStrategy() - Method in interface io.servicetalk.http.api.HttpExecutionContext: Returns the HttpExecutionStrategy associated with this context.
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(ES) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Sets the ExecutionStrategy to use.
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Sets the HttpExecutionStrategy to be used by this server.
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder: Sets the HttpExecutionStrategy to be used for client callbacks when executing client requests for all clients created from this builder.
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Deprecated.
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder: Sets the HttpExecutionStrategy to be used for client callbacks when executing client requests for all clients created from this builder.
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Specifies an HttpExecutionStrategy to be used for this route.
ExecutionStrategy - Interface in io.servicetalk.transport.api: An execution strategy for all transports.
ExecutionStrategyInfluencer<S extends ExecutionStrategy> - Interface in io.servicetalk.transport.api: An entity that wishes to influence the ExecutionStrategy for a server or client.
executor - Variable in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
executor() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
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(Executor) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
executor(Executor) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
executor(Executor) - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
executor(Executor) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
executor(Executor) - Method in interface io.servicetalk.http.api.HttpServerBuilder: Sets the Executor to be used by this server.
executor(Executor) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder
executor(Executor) - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder: Deprecated.
executor(Executor) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
executor(Executor) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder: Sets an Executor to use when required.
executor(Executor) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Sets the Executor to use.
Executor - Interface in io.servicetalk.concurrent.api: A general abstraction to execute immediate and delayed tasks.
Executor - Interface in io.servicetalk.concurrent: A general abstraction to execute immediate and delayed tasks.
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: Create a new HttpResponseStatus.EXPECTATION_FAILED response.
expectationFailed() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.EXPECTATION_FAILED response.
expectationFailed() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.EXPECTATION_FAILED response.
ExpectationFailedException - Exception in io.servicetalk.http.netty: An exception that represents 417 Expectation Failed response status code.
expectCancellable() - Method in interface io.servicetalk.concurrent.api.test.CompletableFirstStep: Declare an expectation that CompletableSource.Subscriber.onSubscribe(Cancellable) is the next signal.
expectCancellable() - Method in interface io.servicetalk.concurrent.api.test.SingleFirstStep: Declare an expectation that SingleSource.Subscriber.onSubscribe(Cancellable) is the next signal.
expectCancellableConsumed(Consumer<? super Cancellable>) - Method in interface io.servicetalk.concurrent.api.test.CompletableFirstStep: Declare an expectation that can be asserted when the CompletableSource.Subscriber.onSubscribe(Cancellable) method is called.
expectCancellableConsumed(Consumer<? super Cancellable>) - Method in interface io.servicetalk.concurrent.api.test.SingleFirstStep: Declare an expectation that can be asserted when the SingleSource.Subscriber.onSubscribe(Cancellable) method is called.
expectComplete() - Method in interface io.servicetalk.concurrent.api.test.CompletableLastStep: Declare an expectation that CompletableSource.Subscriber.onComplete() onComplete} will be the next signal.
expectComplete() - Method in interface io.servicetalk.concurrent.api.test.PublisherLastStep: Declare an expectation that PublisherSource.Subscriber.onComplete() onComplete} will be the next signal.
expectError() - Method in interface io.servicetalk.concurrent.api.test.CompletableLastStep: Declare an expectation that onError will be the next signal.
expectError() - Method in interface io.servicetalk.concurrent.api.test.PublisherLastStep: Declare an expectation that onError will be the next signal.
expectError() - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onError will be the next signal.
expectError(Class<? extends Throwable>) - Method in interface io.servicetalk.concurrent.api.test.CompletableLastStep: Declare an expectation that onError will be the next signal and it will be of type errorClass.
expectError(Class<? extends Throwable>) - Method in interface io.servicetalk.concurrent.api.test.PublisherLastStep: Declare an expectation that onError will be the next signal and it will be of type errorClass.
expectError(Class<? extends Throwable>) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onError will be the next signal and it will be of type errorClass.
expectErrorConsumed(Consumer<Throwable>) - Method in interface io.servicetalk.concurrent.api.test.CompletableLastStep: Declare an expectation that onError will be the next signal and evaluate it with errorConsumer.
expectErrorConsumed(Consumer<Throwable>) - Method in interface io.servicetalk.concurrent.api.test.PublisherLastStep: Declare an expectation that onError will be the next signal and evaluate it with errorConsumer.
expectErrorConsumed(Consumer<Throwable>) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onError will be the next signal and evaluate it with errorConsumer.
expectErrorMatches(Predicate<Throwable>) - Method in interface io.servicetalk.concurrent.api.test.CompletableLastStep: Declare an expectation that onError will be the next signal and evaluate it with errorPredicate.
expectErrorMatches(Predicate<Throwable>) - Method in interface io.servicetalk.concurrent.api.test.PublisherLastStep: Declare an expectation that onError will be the next signal and evaluate it with errorPredicate.
expectErrorMatches(Predicate<Throwable>) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onError will be the next signal and evaluate it with errorPredicate.
expectNext(long, long, Consumer<? super Iterable<? extends T>>) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Expect between [min, max] onNext signals, and assert their values via signalsConsumer.
expectNext(long, Consumer<? super Iterable<? extends T>>) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Expect n onNext signals, and assert their values via signalsConsumer.
expectNext(T) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Declare an expectation that signal will be the next signal.
expectNext(T...) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Declare an expectation that signals will be the next in-order sequence of signals.
expectNextConsumed(Consumer<? super T>) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Declare an expectation that onNext will be the next signal and evaluate it with signalConsumer.
expectNextCount(long) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Expect between [min, max] onNext signals, and discard the values.
expectNextCount(long, long) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Expect between [min, max] onNext signals, and discard the values.
expectNextMatches(Predicate<? super T>) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Declare an expectation that onNext will be the next signal and evaluate it with signalPredicate.
expectNextSequence(Iterable<? extends T>) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Declare an expectation that signals will be the next in-order sequence of signals.
expectNoSignals(Duration) - Method in interface io.servicetalk.concurrent.api.test.CompletableLastStep: Expect no signals in duration time.
expectNoSignals(Duration) - Method in interface io.servicetalk.concurrent.api.test.PublisherStep: Expect no PublisherSource.Subscriber.onNext(Object), PublisherSource.Subscriber.onError(Throwable), or PublisherSource.Subscriber.onComplete() signals in duration time.
expectNoSignals(Duration) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Expect no signals in duration time.
expectSubscription() - Method in interface io.servicetalk.concurrent.api.test.PublisherFirstStep: Declare an expectation that PublisherSource.Subscriber.onSubscribe(Subscription) is the next signal.
expectSubscriptionConsumed(Consumer<? super PublisherSource.Subscription>) - Method in interface io.servicetalk.concurrent.api.test.PublisherFirstStep: Declare an expectation that can be asserted when the PublisherSource.Subscriber.onSubscribe(Subscription) method is called.
expectSuccess() - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onSuccess will be the next signal.
expectSuccess(T) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onSuccess will be the next signal.
expectSuccessConsumed(Consumer<? super T>) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onSuccess will be the next signal and verify it with onSuccessConsumer.
expectSuccessMatches(Predicate<? super T>) - Method in interface io.servicetalk.concurrent.api.test.SingleLastStep: Declare an expectation that onSuccess will be the next signal and verify it with onSuccessPredicate.
EXPIRED - Static variable in class io.servicetalk.client.api.ServiceDiscovererEvent.Status: Signifies the ServiceDiscovererEvent.address() is expired and should not be used for establishing new connections.
expires() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
expires() - Method in interface io.servicetalk.http.api.HttpSetCookie: Returns the expire date of this HttpSetCookie according to Expires.
EXPIRES - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "expires"
extract(C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanContextExtractor: Extract the trace state from a carrier.
extract(Format<C>, C) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
extract(Format<C>, C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
extract(SingleLineValue) - Method in class io.servicetalk.opentracing.inmemory.SingleLineFormatter
extract(T) - Method in class io.servicetalk.opentracing.inmemory.B3KeyValueFormatter
extractByteBufOrCreate(Buffer) - Static method in class io.servicetalk.buffer.netty.BufferUtils: Converts the passed buffer to ByteBuf, creating a new ByteBuf instance if required.
extractSslSessionAndReport(ChannelPipeline, SslHandshakeCompletionEvent, Consumer<Throwable>, boolean) - Static method in class io.servicetalk.transport.netty.internal.NettyPipelineSslUtils: Extracts the SSLSession from the ChannelPipeline if the SslHandshakeCompletionEvent is successful and reports the result to ConnectionObserver.SecurityHandshakeObserver if available.
extractSslSessionAndReport(SslConfig, ChannelPipeline, ConnectionObserver) - Static method in class io.servicetalk.transport.netty.internal.NettyPipelineSslUtils: Extracts the SSLSession from the ChannelPipeline if the handshake is already done and reports the result to ConnectionObserver.SecurityHandshakeObserver if available.

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
FAILED_PRECONDITION - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode: The action cannot be executed on the current system state.
failedDependency() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.FAILED_DEPENDENCY response.
failedDependency() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.FAILED_DEPENDENCY response.
failedDependency() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.FAILED_DEPENDENCY response.
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.http.netty.RetryingHttpRequesterFilter.HttpResponseException
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.
FilterableReservedStreamingHttpConnection - Interface in io.servicetalk.http.api: A special type of StreamingHttpConnection for the exclusive use of the caller of StreamingHttpClient.reserveConnection(HttpRequestMetaData).
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.
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.