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

A

AbstractCloseableIterable<T> - Class in io.servicetalk.concurrent.internal: An abstract implementation of CloseableIterable that wraps an Iterable.
AbstractCloseableIterable(Iterable<T>) - Constructor for class io.servicetalk.concurrent.internal.AbstractCloseableIterable: New instance.
AbstractCloseableIteratorAsInputStream<T> - Class in io.servicetalk.concurrent.internal: Conversion from a CloseableIterator to a InputStream given a Function to serialize to bytes.
AbstractCloseableIteratorAsInputStream(CloseableIterator<T>) - Constructor for class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream: Create a new instance.
AbstractRetryingFilterBuilder<Builder extends AbstractRetryingFilterBuilder<Builder,Filter,Meta>,Filter,Meta> - Class in io.servicetalk.client.api: An abstract builder for retrying filters.
AbstractRetryingFilterBuilder() - Constructor for class io.servicetalk.client.api.AbstractRetryingFilterBuilder
AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<Meta> - Class in io.servicetalk.client.api: A read-only settings for retryable filters.
ACCEPT - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept"
accept(Object, Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
accept(Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer: Same as StatelessTrailersTransformer.accept(Object, Object) but without the state.
accept(State, Payload) - Method in interface io.servicetalk.http.api.TrailersTransformer: Accepts a Payload.
accept(ConnectionContext) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor: Evaluate the passed ConnectionContext to accept or reject.
accept(ConnectionContext) - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
ACCEPT_ALL - Static variable in interface io.servicetalk.transport.api.ConnectionAcceptor: ACCEPT all connections.
ACCEPT_CHARSET - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept-charset"
ACCEPT_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept-encoding"
ACCEPT_LANGUAGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept-language"
ACCEPT_PATCH - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept-patch"
ACCEPT_RANGES - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "accept-ranges"
accepted() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.ACCEPTED response.
accepted() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.ACCEPTED response.
ACCEPTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 202 Accepted
accepted() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.ACCEPTED response.
ACCESS_CONTROL_ALLOW_CREDENTIALS - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-allow-credentials"
ACCESS_CONTROL_ALLOW_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-allow-headers"
ACCESS_CONTROL_ALLOW_METHODS - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-allow-methods"
ACCESS_CONTROL_ALLOW_ORIGIN - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-allow-origin"
ACCESS_CONTROL_EXPOSE_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-expose-headers"
ACCESS_CONTROL_MAX_AGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-max-age"
ACCESS_CONTROL_REQUEST_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-request-headers"
ACCESS_CONTROL_REQUEST_METHOD - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "access-control-request-method"
activate(InMemorySpan, boolean) - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
activate(Span, boolean) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
activate(InMemorySpan, boolean) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager: Same as InMemoryScopeManager.activate(Span, boolean) but the span must be of type InMemorySpan.
active() - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
active() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
activeSpan() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
activeSpan() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
adaptor() - Method in interface io.servicetalk.http.api.HttpApiConversions.ServiceAdapterHolder: StreamingHttpService that adapts another service to the streaming programming model.
add(PartitionAttributes.Key<T>, T) - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
add(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
add(PartitionAttributes.Key<T>, T) - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder: Add a key/value pair to this builder.
add(PartitionAttributes) - Method in interface io.servicetalk.client.api.partition.PartitionMap: Add a new PartitionAttributes that is absolutely specified.
add(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
add(CharSequence, Iterable<? extends CharSequence>) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
add(CharSequence, CharSequence...) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
add(HttpHeaders) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
add(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a new header with the specified name and value.
add(CharSequence, Iterable<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds new headers with the specified name and values.
add(CharSequence, Iterator<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds new headers with the specified name and values.
add(CharSequence, CharSequence...) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds new headers with the specified name and values.
add(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds all header names and values of headers to this object.
addBlockingRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: 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: Adds a GrpcRoutes.BlockingRequestStreamingRoute to this factory.
addBlockingResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - 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: Adds a GrpcRoutes.BlockingResponseStreamingRoute to this factory.
addBlockingRoute(String, Class<?>, String, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBlockingStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBuffer(Buffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer: Add the given Buffer to this buffer and increment the writerIndex.
addBuffer(Buffer, boolean) - Method in interface io.servicetalk.buffer.api.CompositeBuffer: Add the given Buffer to this buffer.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addCookie(HttpCookiePair) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addCookie(HttpCookiePair) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a cookie.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a cookie with the specified name and value.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a cookie.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a cookie with the specified name and value.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequest
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponse
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addHeader(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a new header with the specified name and value.
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addHeaders(HttpHeaders) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds all header names and values of headers object.
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequest
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponse
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addIfAbsent(Channel) - Method in class io.servicetalk.transport.netty.internal.ChannelSet: Add a Channel to this ChannelSet, if it is not already present.
addListener(InMemorySpanEventListener) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder: Add a trace event listener.
addOption(Map<ChannelOption, Object>, SocketOption<T>, Object) - Static method in class io.servicetalk.transport.netty.internal.SocketOptionUtils: Convert and add the given SocketOption and value to the ChannelOptions Map.
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequest
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Adds a new query parameter with the specified key and value, which will be percent-encoded if needed.
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.HttpRequest
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequest
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Adds new query parameters with the specified key and values.
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Adds new query parameters with the specified key and values.
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addReference(String, SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
addReference(String, InMemorySpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder: Same as InMemorySpanBuilder.addReference(String, SpanContext) but requires a InMemorySpanContext.
addRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addRequestStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
addResponseStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
address() - Method in class io.servicetalk.client.api.DefaultGroupKey
address() - Method in class io.servicetalk.client.api.DefaultServiceDiscovererEvent
address() - Method in interface io.servicetalk.client.api.GroupKey: Get the address to use when looking for or creating a new client.
address() - Method in interface io.servicetalk.client.api.ServiceDiscovererEvent: Get the resolved address which is the subject of this event.
addRoute(String, Class<?>, String, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.Route to this factory.
addRoute(String, GrpcExecutionStrategy, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.Route to this factory.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
addSetCookie(HttpSetCookie) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addSetCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.BlockingStreamingHttpServerResponse
addSetCookie(HttpSetCookie) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a set-cookie.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Adds a set-cookie with the specified name and value.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a set-cookie.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData: Adds a set-cookie with the specified name and value.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequest
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponse
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
addStreamingRoute(String, Class<?>, String, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.StreamingRoute to this factory.
addStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes: Adds a GrpcRoutes.StreamingRoute to this factory.
addTrailer(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.HttpOutputStream
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpPayloadWriter
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
addTrailers(HttpHeaders) - Method in class io.servicetalk.http.api.HttpOutputStream
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpPayloadWriter
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequest
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponse
addWithOverflowProtection(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Adds two positive longs and returns Long.MAX_VALUE if overflow occurs.
addWithOverflowProtection(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Adds two positive ints and returns Integer.MAX_VALUE if overflow occurs.
addWithOverflowProtection(AtomicIntegerFieldUpdater<T>, T, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Increment an integer referred by AtomicIntegerFieldUpdater atomically and saturate to Integer.MAX_VALUE if overflow occurs.
addWithOverflowProtection(AtomicLongFieldUpdater<T>, T, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: Increment a long referred by AtomicLongFieldUpdater atomically and saturate to Long.MAX_VALUE if overflow occurs.
addWithOverflowProtectionIfGtEqNegativeOne(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: If x is >=-1 this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithOverflowProtectionIfNotNegative(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: If x is non-negative this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithOverflowProtectionIfNotNegative(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: If x is non-negative this method behaves the same as FlowControlUtils.addWithOverflowProtection(int, int).
addWithOverflowProtectionIfPositive(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: If x is positive this method behaves the same as FlowControlUtils.addWithOverflowProtection(int, int).
addWithOverflowProtectionIfPositive(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils: If x is positive this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator: 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.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Completable: Invokes the onCancel Runnable argument after Cancellable.cancel() is called for Subscriptions of the returned Completable.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher: Invokes the onCancel Runnable argument after Cancellable.cancel() is called for PublisherSource.Subscriptions of the returned Publisher.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Single: Invokes the onCancel Runnable argument after Cancellable.cancel() is called for Subscriptions of the returned Single.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Completable: Invokes the whenFinally Runnable argument after any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() CompletableSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher: Invokes the whenFinally 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<Cancellable>) - Method in class io.servicetalk.concurrent.api.Completable: Invokes the onSubscribe Consumer argument after CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
afterOnSubscribe(Consumer<? super PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher: Invokes the onSubscribe Consumer argument after PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Single: Invokes the onSubscribe Consumer argument after SingleSource.Subscriber.onSubscribe(Cancellable) is called for SingleSource.Subscribers of the returned Single.
afterOnSuccess(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single: Invokes the onSuccess Consumer argument after SingleSource.Subscriber.onSuccess(Object) is called for SingleSource.Subscribers of the returned Single.
afterRequest(LongConsumer) - Method in class io.servicetalk.concurrent.api.Publisher: Invokes the onRequest LongConsumer argument after PublisherSource.Subscription.request(long) is called for PublisherSource.Subscriptions of the returned Publisher.
afterSubscriber(Supplier<? extends CompletableSource.Subscriber>) - Method in class io.servicetalk.concurrent.api.Completable: Creates a new CompletableSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the CompletableSource.Subscriber methods after the CompletableSource.Subscribers of the returned Completable.
afterSubscriber(Supplier<? extends PublisherSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Publisher: Creates a new PublisherSource.Subscriber (via the subscriberSupplier argument) for each new subscribe and invokes all the PublisherSource.Subscriber methods after the PublisherSource.Subscribers of the returned Publisher.
afterSubscriber(Supplier<? extends SingleSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Single: Creates a new SingleSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the SingleSource.Subscriber methods after the SingleSource.Subscribers of the returned Single.
afterSubscription(Supplier<? extends PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher: Creates a new PublisherSource.Subscription (via the subscriptionSupplier argument) for each new subscribe and invokes all the PublisherSource.Subscription methods after the PublisherSource.Subscriptions of the returned Publisher.
AGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "age"
allocateMemory(long) - Static method in class io.servicetalk.utils.internal.PlatformDependent: Allocates direct memory.
ALLOW - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "allow"
alpnId() - Method in interface io.servicetalk.http.api.HttpProtocolConfig: TLS Application-Layer Protocol Negotiation (ALPN) Protocol ID of the protocol this configuration is for.
alpnId() - Method in interface io.servicetalk.http.netty.H1ProtocolConfig
alpnId() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig
ALREADY_REPORTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 208 Already Reported
alreadyReported() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: 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.
and(Predicate<StreamingHttpRequest>) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches StreamingHttpRequests with a user-specified predicate.
and(BiPredicate<ConnectionContext, StreamingHttpRequest>) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches StreamingHttpRequest and ConnectionContext with a user-specified predicate.
andCookie(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route with a CookieMatcher that matches against HttpSetCookies with the name name.
andHeader(CharSequence) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route with a StringMultiValueMatcher that matches against the value(s) of the name headers.
andIsNotSsl() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests that are not over SSL/TLS.
andIsSsl() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests that are over SSL/TLS.
andMethod(HttpRequestMethod) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the HttpRequestMethod is method.
andMethodIsOneOf(HttpRequestMethod...) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the HttpRequestMethod is one of the methods.
andPathEquals(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the path is equal to path.
andPathIsOneOf(String...) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the path is equal to any of the specified paths.
andPathMatches(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the path matches the regex pathRegex.
andPathMatches(Pattern) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the path matches the regex pathRegex.
andPathStartsWith(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route such that it matches requests where the path starts with pathPrefix.
andQueryParam(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Extends the current route with a StringMultiValueMatcher that matches against the value(s) of the request parameter name.
andThen(ChannelInitializer) - Method in interface io.servicetalk.transport.netty.internal.ChannelInitializer: Returns a new ChannelInitializer which will first invoke this initializer and then after.
append(ConnectionFactoryFilter<ResolvedAddress, C>) - Method in interface io.servicetalk.client.api.ConnectionFactoryFilter: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(ServiceDiscovererFilterFactory<UnresolvedAddress, ResolvedAddress, Event>) - Method in interface io.servicetalk.client.api.ServiceDiscovererFilterFactory: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(T) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable: Appends the passed AsyncCloseable with this CompositeCloseable such that when this CompositeCloseable is closed, all of the previously registered AsyncCloseables are closed too.
append(GrpcServiceFilterFactory<Filter, Service>) - Method in interface io.servicetalk.grpc.api.GrpcServiceFilterFactory: Returns a composed factory that first applies the before factory to its input, and then applies this factory to the result.
append(MultiAddressHttpClientFilterFactory<U>) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(PartitionHttpClientBuilderConfigurator<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator: Appends the passed PartitionHttpClientBuilderConfigurator to this PartitionHttpClientBuilderConfigurator such that this PartitionHttpClientBuilderConfigurator is applied first and then the passed PartitionHttpClientBuilderConfigurator.
append(HttpExecutionStrategyInfluencer) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: Append another HttpExecutionStrategyInfluencer to this chain.
append(StreamingHttpClientFilterFactory) - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(StreamingHttpConnectionFilterFactory) - Method in interface io.servicetalk.http.api.StreamingHttpConnectionFilterFactory: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.StreamingHttpServiceFilterFactory: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor: Returns a composed ConnectionAcceptor that first applies this ConnectionAcceptor, and if this is successful then applies after ConnectionAcceptor.
append(ConnectionAcceptorFactory) - Method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
appendAll(AsyncCloseable...) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable: Appends all the passed AsyncCloseables with this CompositeCloseable such that when this CompositeCloseable is closed, all of these AsyncCloseables are closed too.
appendAll(Iterable<? extends AsyncCloseable>) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable: Appends all the passed AsyncCloseables with this CompositeCloseable such that when this CompositeCloseable is closed, all of these AsyncCloseables are closed too.
appendClientBuilderFilter(PartitionHttpClientBuilderConfigurator<U, R>) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder: Sets a function that allows customizing the SingleAddressHttpClientBuilder used to create the client for a given partition based on its PartitionAttributes.
appendClientFilter(FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientFactory: Appends the passed FilterFactory to this factory.
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
appendClientFilter(MultiAddressHttpClientFilterFactory<U>) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the StreamingHttpClient created by this builder for a given UnresolvedAddress.
appendClientFilter(Predicate<StreamingHttpRequest>, MultiAddressHttpClientFilterFactory<U>) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder: Appends the filter to the chain of filters used to decorate the StreamingHttpClient created by this builder for a given UnresolvedAddress, for every request that passes the provided Predicate.
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
appendClientFilterFactory(FilterFactory, FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientFactory: Appends the passed FilterFactory to this client factory.
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Append the filter to the chain of filters used to decorate the ConnectionAcceptor used by this builder.
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in class io.servicetalk.http.api.HttpServerBuilder: Appends the filter to the chain of filters used to decorate the ConnectionAcceptor used by this builder.
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
appendFilter(ServiceDiscovererFilterFactory<String, InetAddress, ServiceDiscovererEvent<InetAddress>>) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Append the filter to the chain of filters used to decorate the ServiceDiscoverer created by this builder.
appendHttpClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder: Append the filter to the chain of filters used to decorate the client created by this builder.
appendHttpClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder: Append the filter to the chain of filters used to decorate the client created by this builder, for every request that passes the provided Predicate.
appendHttpServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Append the filter to the chain of filters used to decorate the service used by this builder.
appendHttpServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Append the filter to the chain of filters used to decorate the service used by this builder, for every request that passes the provided Predicate.
appendIfInfluencer(Object) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder: If the passed mayBeInfluencer is an HttpExecutionStrategyInfluencer then add it to this chain.
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.HttpRequest
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Appends segments to the current HttpRequestMetaData.path(), performing encoding of each segment (including ('/') characters) according to percent-encoding.
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
appendServiceFilter(FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServiceFactory: Appends the passed FilterFactory to this factory.
appendServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.HttpServerBuilder: Appends the filter to the chain of filters used to decorate the StreamingHttpService used by this builder.
appendServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.HttpServerBuilder: Appends the filter to the chain of filters used to decorate the StreamingHttpService used by this builder, for every request that passes the provided Predicate.
appendServiceFilterFactory(FilterFactory, FilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServiceFactory: Appends the passed FilterFactory to this service factory.
APPLICATION_JSON - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "application/json"
APPLICATION_X_WWW_FORM_URLENCODED - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "application/x-www-form-urlencoded"
APPLICATION_X_WWW_FORM_URLENCODED_UTF_8 - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "application/x-www-form-urlencoded; charset=UTF-8"
applicationStatus() - Method in exception io.servicetalk.grpc.api.GrpcStatusException: Returns the status details if any was included or null.
apply(PartitionAttributes, ServiceDiscoverer<U, R, ? extends PartitionedServiceDiscovererEvent<R>>) - Method in interface io.servicetalk.client.api.internal.DefaultPartitionedClientGroup.PartitionedClientFactory: Create a partitioned client.
apply(int, T) - Method in interface io.servicetalk.concurrent.api.BiIntFunction: Evaluates this function on the given arguments.
apply(CompletableSource.Subscriber) - Method in interface io.servicetalk.concurrent.api.CompletableOperator: Implementation of this operator.
apply(PublisherSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherOperator: Implementation of this operator.
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherToSingleOperator: Implementation of this operator.
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.SingleOperator: Implementation of this operator.
apply(String, String) - Method in interface io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.CredentialsVerifier: Verifies user-id and password, parsed from the 'Basic' HTTP Authentication Scheme credentials.
apply(SingleSource.Subscriber<? super StreamingHttpResponse>) - Method in class io.servicetalk.http.utils.BeforeFinallyOnHttpResponseOperator
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
array() - Method in interface io.servicetalk.buffer.api.Buffer: Returns the backing byte array of this buffer.
array() - Method in class io.servicetalk.buffer.api.EmptyBuffer
arrayOffset() - Method in interface io.servicetalk.buffer.api.Buffer: Returns the offset of the first byte within the backing byte array of this buffer.
arrayOffset() - Method in class io.servicetalk.buffer.api.EmptyBuffer
ArrayUtils - Class in io.servicetalk.concurrent.internal: Utilities for arrays.
asBlockingClient() - Method in interface io.servicetalk.grpc.api.GrpcClient: Converts this GrpcClient to a blocking client.
asBlockingClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient: 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.HttpConnection: Convert this HttpConnection to the BlockingHttpConnection API.
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
asBlockingConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection: 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.HttpConnection: Convert this HttpConnection to the BlockingStreamingHttpConnection API.
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(SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
asChildOf(Span) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
asClient() - Method in interface io.servicetalk.grpc.api.BlockingGrpcClient: Converts this BlockingGrpcClient to a client.
asClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient: Convert this BlockingHttpClient to the HttpClient API.
asClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient: Convert this BlockingStreamingHttpClient to the HttpClient API.
asClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient: Convert this StreamingHttpClient to the HttpClient API.
asClientFilter(U) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientFilterFactory: Returns a StreamingHttpClientFilterFactory that adapts from a MultiAddressHttpClientFilterFactory.
asConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection: Convert this BlockingHttpConnection to the HttpConnection API.
asConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection: Convert this BlockingStreamingHttpConnection to the HttpConnection API.
asConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
asConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
asConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
asConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection: Convert this StreamingHttpConnection to the HttpConnection API.
asException() - Method in class io.servicetalk.grpc.api.GrpcStatus: Returns the current status wrapped in a GrpcStatusException.
asException(Supplier<Status>) - Method in class io.servicetalk.grpc.api.GrpcStatus: Returns the current status wrapped in a GrpcStatusException including the supplied details.
asExecutor() - Method in interface io.servicetalk.transport.netty.internal.NettyIoExecutor: Get an Executor which will use an IoExecutor thread for execution.
asInputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer: Return an InputStream that wraps the given Buffer.
asMultiAddressClientFilter() - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory: Returns a MultiAddressHttpClientFilterFactory that adapts from a StreamingHttpClientFilterFactory.
asOutputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer: Return an OutputStream that wraps the given Buffer.
asReadOnly() - Method in interface io.servicetalk.buffer.api.Buffer: Create a read-only view for this buffer.
asReadOnly() - Method in class io.servicetalk.buffer.api.EmptyBuffer
asReadOnly(List<String>) - Method in class io.servicetalk.tcp.netty.internal.TcpClientConfig
asReadOnly(List<String>) - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig
asReadOnly() - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Returns this config as a ReadOnlyClientSecurityConfig.
asReadOnly() - Method in class io.servicetalk.transport.netty.internal.ServerSecurityConfig: Returns this config as a ReadOnlyServerSecurityConfig.
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.
AsyncContextMap - Interface in io.servicetalk.concurrent.api: The key-value map stored in the AsyncContext.
asyncContextMap(AsyncContextMap) - Method in interface io.servicetalk.concurrent.api.AsyncContextMapHolder: Set the AsyncContextMap.
asyncContextMap() - Method in interface io.servicetalk.concurrent.api.AsyncContextMapHolder: Get the current AsyncContextMap.
AsyncContextMap.Key<T> - Class in io.servicetalk.concurrent.api: A key identifies a specific object in a AsyncContextMap.
AsyncContextMapHolder - Interface in io.servicetalk.concurrent.api: Interface for setting and getting a AsyncContextMap.
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.
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
autoRetryStrategy(AutoRetryStrategyProvider) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
AutoRetryStrategyProvider - Interface in io.servicetalk.client.api: A provider for AutoRetryStrategyProvider.AutoRetryStrategy.
AutoRetryStrategyProvider.AutoRetryStrategy - Interface in io.servicetalk.client.api: A strategy to use for automatic retries.
available() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
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.
awaitTermination(Future<Void>) - Static method in class io.servicetalk.concurrent.internal.FutureUtils: Await the completion of the passed Future.

B

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

C

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

D

datagramChannel(EventLoopGroup) - Static method in class io.servicetalk.transport.netty.internal.BuilderUtils: Returns the correct Class to use with the given EventLoopGroup.
DATE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "date"
decode(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder: Decode the from one ByteBuf to an other.
decodeLast(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder: Is called one last time when the ChannelHandlerContext goes in-active.
DEFAULT_ALLOCATOR - Static variable in class io.servicetalk.buffer.netty.BufferAllocators: Default BufferAllocator whose Buffers are typically backed by Netty buffers.
DEFAULT_HEADER_FILTER - Static variable in class io.servicetalk.http.api.HeaderUtils
DEFAULT_NAME_PREFIX - Static variable in class io.servicetalk.concurrent.api.DefaultThreadFactory
DEFAULT_RO_ALLOCATOR - Static variable in class io.servicetalk.buffer.api.ReadOnlyBufferAllocators: Default BufferAllocator that creates Buffer instances which cannot be modified and are read only.
DefaultAutoRetryStrategyProvider - Class in io.servicetalk.client.api: Default implementation for AutoRetryStrategyProvider.
DefaultAutoRetryStrategyProvider.Builder - Class in io.servicetalk.client.api: A builder for DefaultAutoRetryStrategyProvider.
DefaultDnsServiceDiscovererBuilder - Class in io.servicetalk.dns.discovery.netty: Builder use to create objects of type DefaultDnsServiceDiscoverer.
DefaultDnsServiceDiscovererBuilder() - Constructor for class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
DefaultExecutionContext - Class in io.servicetalk.transport.api: A default implementation of ExecutionContext.
DefaultExecutionContext(BufferAllocator, IoExecutor, Executor, ExecutionStrategy) - Constructor for class io.servicetalk.transport.api.DefaultExecutionContext: Create a new instance.
defaultFlushStrategy() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
defaultFlushStrategy() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection
defaultFlushStrategy() - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies: Creates a default FlushStrategy.
defaultFlushStrategy() - Method in interface io.servicetalk.transport.netty.internal.NettyConnectionContext: Returns the FlushStrategy used by default for this NettyConnectionContext.
DefaultGroupKey<Address> - Class in io.servicetalk.client.api: A default implementation of GroupKey.
DefaultGroupKey(Address, ExecutionContext) - Constructor for class io.servicetalk.client.api.DefaultGroupKey: Create a new instance.
DefaultGrpcClientMetadata - Class in io.servicetalk.grpc.api: Default implementation for DefaultGrpcClientMetadata.
DefaultGrpcClientMetadata(String) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata: Creates a new instance.
DefaultGrpcClientMetadata(String, GrpcExecutionStrategy) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata: Creates a new instance.
DefaultHttpCookiePair - Class in io.servicetalk.http.api: Default implementation of HttpCookiePair.
DefaultHttpCookiePair(CharSequence, CharSequence) - Constructor for class io.servicetalk.http.api.DefaultHttpCookiePair: Create a new instance.
DefaultHttpCookiePair(CharSequence, CharSequence, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpCookiePair: Create a new instance.
DefaultHttpExecutionContext - Class in io.servicetalk.http.api: Default implementation of HttpExecutionContext.
DefaultHttpExecutionContext(BufferAllocator, IoExecutor, Executor, HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.DefaultHttpExecutionContext: Create a new instance.
DefaultHttpHeadersFactory - Class in io.servicetalk.http.api: Default implementation of HttpHeadersFactory.
DefaultHttpHeadersFactory(boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory: Create an instance of the factory with the default array size hint.
DefaultHttpHeadersFactory(boolean, boolean, int, int) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory: Create an instance of the factory.
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, boolean, boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie: Creates a new HttpSetCookie instance.
defaultInitializer() - Static method in interface io.servicetalk.transport.netty.internal.ChannelInitializer: Default ChannelInitializer.
DefaultInMemoryTracer - Class in io.servicetalk.opentracing.inmemory: Tracer implementation that propagates spans in-memory and emits events to listeners.
DefaultInMemoryTracer.Builder - Class in io.servicetalk.opentracing.inmemory: Builders for DefaultInMemoryTracer.
DefaultInMemoryTraceState - Class in io.servicetalk.opentracing.inmemory: Default implementation of InMemoryTraceState.
DefaultInMemoryTraceState(String, String, String, boolean) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemoryTraceState: Constructs an instance.
defaultInvalidateHostsOnDnsFailurePredicate() - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Returns a default value for DefaultDnsServiceDiscovererBuilder.invalidateHostsOnDnsFailure(Predicate).
DefaultNettyConnection<Read,Write> - Class in io.servicetalk.transport.netty.internal: Implementation of NettyConnection backed by a netty Channel.
DefaultNettyPipelinedConnection<Req,Resp> - Class in io.servicetalk.transport.netty.internal: Implementation of NettyPipelinedConnection using a NettyConnection.
DefaultNettyPipelinedConnection(NettyConnection<Resp, Req>, int) - Constructor for class io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection: New instance.
defaultOffloaderFactory() - Static method in class io.servicetalk.concurrent.internal.SignalOffloaders: Return a default SignalOffloaderFactory.
DefaultPartitionAttributesBuilder - Class in io.servicetalk.client.api.internal.partition: Default implementation of PartitionAttributesBuilder.
DefaultPartitionAttributesBuilder(int) - Constructor for class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder: Create a new instance.
DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api.internal: An implementation of ClientGroup that can be used for partitioned client use-cases where PartitionAttributes are discovered through PartitionedServiceDiscovererEvents.
DefaultPartitionedClientGroup(Function<PartitionAttributes, Client>, Function<PartitionAttributes, Client>, DefaultPartitionedClientGroup.PartitionedClientFactory<U, R, Client>, PartitionMapFactory, Publisher<? extends PartitionedServiceDiscovererEvent<R>>, int) - Constructor for class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup: Creates a new instance.
DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> - Interface in io.servicetalk.client.api.internal: Factory for building partitioned clients.
defaultRetryForPredicate() - Method in class io.servicetalk.client.api.AbstractRetryingFilterBuilder: Returns a default value for AbstractRetryingFilterBuilder.retryFor(BiPredicate).
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: Default implementation for Serializer.
DefaultSerializer(SerializationProvider) - Constructor for class io.servicetalk.serialization.api.DefaultSerializer: New instance.
DefaultServiceDiscovererEvent<T> - Class in io.servicetalk.client.api: Default implementation of ServiceDiscovererEvent.
DefaultServiceDiscovererEvent(T, boolean) - Constructor for class io.servicetalk.client.api.DefaultServiceDiscovererEvent: Create a new instance.
defaultStrategy() - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies: The default GrpcExecutionStrategy.
defaultStrategy(Executor) - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies: The default GrpcExecutionStrategy using the passed Executor.
defaultStrategy() - Static method in class io.servicetalk.http.api.HttpExecutionStrategies: The default HttpExecutionStrategy.
defaultStrategy(Executor) - Static method in class io.servicetalk.http.api.HttpExecutionStrategies: The default HttpExecutionStrategy using the passed Executor.
defaultStrategyFactory() - Static method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory: 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: Returns an HttpExecutionStrategyInfluencer to be used for the default streaming programming model.
DefaultTestCerts - Class in io.servicetalk.test.resources: Provides a set of certificates useful for tests that require SSL.
DefaultThreadFactory - Class in io.servicetalk.concurrent.api: A ThreadFactory implementation.
DefaultThreadFactory() - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory: New instance that creates daemon threads with Thread.NORM_PRIORITY priority.
DefaultThreadFactory(boolean) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory: New instance that creates threads with Thread.NORM_PRIORITY priority.
DefaultThreadFactory(int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory: New instance that creates daemon threads.
DefaultThreadFactory(String) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory: Create a new instance.
DefaultThreadFactory(boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory: New instance.
DefaultThreadFactory(String, boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory: New instance.
defer(Supplier<? extends Completable>) - Static method in class io.servicetalk.concurrent.api.Completable: Defer creation of a Completable till it is subscribed to.
defer(Supplier<? extends Publisher<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Publisher: Defers creation of a Publisher till it is subscribed.
defer(Supplier<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single: Defer creation of a Single till it is subscribed to.
DeferSslHandler - Class in io.servicetalk.transport.netty.internal: A ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler.
DEFLATE - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "deflate"
DelayedCancellable - Class in io.servicetalk.concurrent.internal: A Cancellable which serves as a placeholder until the "real" Cancellable is available.
DelayedCancellable() - Constructor for class io.servicetalk.concurrent.internal.DelayedCancellable
delayedCancellable(Cancellable) - Method in class io.servicetalk.concurrent.internal.DelayedCancellable: Set the delayed Cancellable.
DelayedSubscription - Class in io.servicetalk.concurrent.internal: A PublisherSource.Subscription which serves as a placeholder until the "real" PublisherSource.Subscription is available.
DelayedSubscription() - Constructor for class io.servicetalk.concurrent.internal.DelayedSubscription
delayedSubscription(PublisherSource.Subscription) - Method in class io.servicetalk.concurrent.internal.DelayedSubscription: Set the delayed PublisherSource.Subscription.
delegate() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory: Returns the ConnectionFactory delegate.
delegate() - Method in class io.servicetalk.http.api.DelegatingHttpConnectionContext: Get the HttpConnectionContext that this class delegates to.
delegate() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter: Get the ReservedStreamingHttpConnection this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter: Get the FilterableStreamingHttpClient this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter: Get the FilterableStreamingHttpConnection this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter: Returns StreamingHttpService to which all calls are delegated.
delegate() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor: The ConnectionAcceptor to which all calls are delegated to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext: Get the ConnectionContext that this class delegates to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext: Get the ExecutionContext that this class delegates to.
delegate() - Method in class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy: Returns the delegate FlushStrategy used.
DelegatingConnectionAcceptor - Class in io.servicetalk.transport.api: An implementation of ConnectionAcceptor that delegates all methods to another ConnectionAcceptor.
DelegatingConnectionAcceptor(ConnectionAcceptor) - Constructor for class io.servicetalk.transport.api.DelegatingConnectionAcceptor: New instance.
DelegatingConnectionContext - Class in io.servicetalk.transport.api: A ConnectionContext implementation that delegates all calls to a provided ConnectionContext.
DelegatingConnectionContext(ConnectionContext) - Constructor for class io.servicetalk.transport.api.DelegatingConnectionContext: New instance.
DelegatingConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api: A ConnectionFactory that delegates all methods to another ConnectionFactory.
DelegatingConnectionFactory(ConnectionFactory<ResolvedAddress, C>) - Constructor for class io.servicetalk.client.api.DelegatingConnectionFactory: Create a new instance.
DelegatingExecutionContext - Class in io.servicetalk.transport.api: An ExecutionContext implementation that delegates all calls to a provided ExecutionContext.
DelegatingExecutionContext(ExecutionContext) - Constructor for class io.servicetalk.transport.api.DelegatingExecutionContext: New instance.
DelegatingExecutor - Class in io.servicetalk.concurrent.api: An Executor that simply delegates all calls to another Executor.
DelegatingExecutor(Executor) - Constructor for class io.servicetalk.concurrent.api.DelegatingExecutor: New instance.
DelegatingFlushStrategy - Class in io.servicetalk.transport.netty.internal: A FlushStrategy implementation that delegates all calls to another FlushStrategy.
DelegatingFlushStrategy(FlushStrategy) - Constructor for class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy: Create a new instance.
DelegatingHttpConnectionContext - Class in io.servicetalk.http.api: HttpConnectionContext implementation that delegates all calls to a provided HttpConnectionContext.
DelegatingHttpConnectionContext(HttpConnectionContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpConnectionContext: New instance.
DelegatingHttpExecutionContext - Class in io.servicetalk.http.api: An implementation of HttpExecutionContext that delegates all method calls to another HttpExecutionContext.
DelegatingHttpExecutionContext(HttpExecutionContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpExecutionContext: Creates a new instance.
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.
delete(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory: Create a new HttpRequestMethod.DELETE request.
delete(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory: Create a new HttpRequestMethod.DELETE request.
DELETE - Static variable in class io.servicetalk.http.api.HttpRequestMethod: HTTP DELETE method.
delete(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory: Create a new HttpRequestMethod.DELETE request.
deliverTerminalFromSource(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.
deliverTerminalFromSource(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.
deliverTerminalFromSource(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.
deliverTerminalFromSource(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.
description() - Method in class io.servicetalk.grpc.api.GrpcStatus: Returns additional descriptions, can be null.
deserialize(HttpHeaders, Buffer) - Method in interface io.servicetalk.http.api.HttpDeserializer: Deserialize a single Object into a T.
deserialize(HttpHeaders, BlockingIterable<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer: Deserialize a BlockingIterable of Objects into a BlockingIterable of type T.
deserialize(HttpHeaders, Publisher<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer: Deserialize a Publisher of Objects into a Publisher of type T.
deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserialize(Publisher<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserialize(Iterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserialize(BlockingIterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Applies a deserializer on the passed Publisher to convert into a Publisher of deserialized instances of T.
deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Applies a deserializer on the passed Iterable to convert into a Iterable of deserialized instances of T.
deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Applies a deserializer on the passed BlockingIterable to convert into a BlockingIterable of deserialized instances of T.
deserialize(Publisher<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Applies a deserializer on the passed Publisher to convert into a Publisher of deserialized instances of T.
deserialize(Iterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Applies a deserializer on the passed Iterable to convert into a CloseableIterable of deserialized instances of T.
deserialize(BlockingIterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Applies a deserializer on the passed BlockingIterable to convert into a Iterable of deserialized instances of T.
deserialize(Buffer) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer: Deserialize the passed Buffer into an Iterable of Ts.
deserialize(Iterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer: Deserialize the passed Iterable of Buffers into an Iterable of Ts.
deserialize(BlockingIterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer: Deserialize the passed BlockingIterable of Buffers into a BlockingIterable of Ts.
deserializeAggregated(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserializeAggregated(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserializeAggregated(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Deserializes the passed encoded Buffer to one or more instances of T.
deserializeAggregated(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Deserializes the passed encoded Buffer to zero or more instances of T.
deserializeAggregatedSingle(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
deserializeAggregatedSingle(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Deserializes the passed encoded Buffer to a single instance of T.
deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer: Deserializes the passed encoded Buffer to a single instance of T.
deserializerFor(GrpcMessageEncoding, Class<T>) - Method in interface io.servicetalk.grpc.api.GrpcSerializationProvider: Get a HttpDeserializer for a Class of type T.
deserializerFor(Class<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider: Get a HttpDeserializer for a Class of type T.
deserializerFor(TypeHolder<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider: Get a HttpDeserializer for a TypeHolder of type T.
detectBoundary(Object) - Method in interface io.servicetalk.transport.netty.internal.SplittingFlushStrategy.FlushBoundaryProvider: Detect the SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for the passed itemWritten.
difference(Executor, HttpExecutionStrategy, HttpExecutionStrategy) - Static method in class io.servicetalk.http.api.HttpExecutionStrategies: Find the difference between two strategies and provide a resulting strategy if there are differences in between the strategies.
disable() - Static method in class io.servicetalk.concurrent.api.AsyncContext: Disable AsyncContext.
DISABLE_AUTO_RETRIES - Static variable in interface io.servicetalk.client.api.AutoRetryStrategyProvider: An AutoRetryStrategyProvider that disables automatic retries;
disableDrainingRequestPayloadBody() - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Disables automatic consumption of request payload body when it is not consumed by the service.
disableDrainingRequestPayloadBody() - Method in class io.servicetalk.http.api.HttpServerBuilder: Disables automatic consumption of request payload body when it is not consumed by the service.
disableHostHeaderFallback() - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
disableHostHeaderFallback() - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
disableHostHeaderFallback() - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
disableHostnameVerification() - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
disableHostnameVerification() - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
disableHostnameVerification() - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
disableHostnameVerification() - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator: Disable verification of the server identity.
disableHostnameVerification() - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Disable verification of the server identity.
disableRetryAllRetryableExceptions() - Method in class io.servicetalk.client.api.DefaultAutoRetryStrategyProvider.Builder: Connection closures (by the peer or locally) and new requests may happen concurrently.
disableWaitForLoadBalancer() - Method in class io.servicetalk.client.api.DefaultAutoRetryStrategyProvider.Builder: By default, automatic retries waits for the associated LoadBalancer to be ready before triggering a retry for requests.
discardIfCurrent(Predicate<Read>) - Method in class io.servicetalk.transport.netty.internal.NettyConnection.TerminalPredicate: Discards the current Predicate (if same as passed current) and sets current as the original Predicate.
discardSomeReadBytes() - Method in interface io.servicetalk.buffer.api.CompositeBuffer: Discard all Buffers which have been read.
discover(UnresolvedAddress) - Method in interface io.servicetalk.client.api.ServiceDiscoverer: Subscribe to the service discovery system for changes in the available ResolvedAddress associated with address.
discover(UnresolvedAddress) - Method in class io.servicetalk.client.api.ServiceDiscovererFilter
discover(String) - Method in class io.servicetalk.dns.discovery.netty.RetryingDnsServiceDiscovererFilter
dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Sets the list of the protocol families of the address resolved.
DnsResolverAddressTypes - Enum in io.servicetalk.dns.discovery.netty: Defined resolved address types.
DnsServerAddressStream - Interface in io.servicetalk.dns.discovery.netty: An infinite stream of DNS server addresses.
dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Set the DnsServerAddressStreamProvider which determines which DNS server should be used per query.
DnsServerAddressStreamProvider - Interface in io.servicetalk.dns.discovery.netty: Provides an opportunity to override which DnsServerAddressStream is used to resolve a specific hostname.
doAppendHttpClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder: Append the filter to the chain of filters used to decorate the client created by this builder.
doAppendHttpClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder: Append the filter to the chain of filters used to decorate the client created by this builder, for every request that passes the provided Predicate.
doAppendHttpServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Append the filter to the chain of filters used to decorate the service used by this builder.
doAppendHttpServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Append the filter to the chain of filters used to decorate the service used by this builder, for every request that passes the provided Predicate.
doClose(boolean) - Method in interface io.servicetalk.concurrent.api.AsyncCloseables.CloseableResource: Supplies the Completable representing the close.
doCloseAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
doCloseAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable: Initiate graceful closure.
doListen(GrpcServiceFactory<?, ?, ?>) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Starts this server and returns the ServerContext after the server has been successfully started.
doListen(ConnectionAcceptor, StreamingHttpService, HttpExecutionStrategy, boolean) - Method in class io.servicetalk.http.api.HttpServerBuilder: Starts this server and returns the ServerContext after the server has been successfully started.
domain() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
domain() - Method in interface io.servicetalk.http.api.HttpSetCookie: Returns the domain of this HttpSetCookie.
domainMatches(CharSequence, CharSequence) - Static method in class io.servicetalk.http.api.HeaderUtils: Domain Matching.
domainNameMapping() - Method in class io.servicetalk.tcp.netty.internal.ReadOnlyTcpServerConfig: Gets DomainNameMapping, if any.
DomainSocketAddress - Class in io.servicetalk.transport.api: An address which represents a socket belonging to the AF_UNIX socket family.
DomainSocketAddress(String) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress: Create a new instance.
DomainSocketAddress(File) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress: Create a new instance.
drainSingleConsumerCollectionDelayThrow(Collection<T>, Consumer<T>, AtomicIntegerFieldUpdater<R>, R) - Static method in class io.servicetalk.concurrent.internal.ConcurrentUtils: Drains the passed single-consumer Collection and ensures that it is empty before returning.
drainSingleConsumerQueue(Queue<T>, Consumer<T>, AtomicIntegerFieldUpdater<R>, R) - Static method in class io.servicetalk.concurrent.internal.ConcurrentUtils: Drains the passed single-consumer Queue and ensures that it is empty before returning.
drainSingleConsumerQueueDelayThrow(Queue<T>, Consumer<T>, AtomicIntegerFieldUpdater<R>, R) - Static method in class io.servicetalk.concurrent.internal.ConcurrentUtils: Drains the passed single-consumer Queue and ensures that it is empty before returning.
duplicate() - Method in interface io.servicetalk.buffer.api.Buffer: Returns a buffer which shares the whole region of this buffer.
duplicate() - Method in interface io.servicetalk.buffer.api.BufferHolder: Duplicates this BufferHolder.
duplicate() - Method in class io.servicetalk.buffer.api.EmptyBuffer
duplicate() - Method in interface io.servicetalk.dns.discovery.netty.DnsServerAddressStream: Duplicate this object.
duplicate() - Method in class io.servicetalk.dns.discovery.netty.SingletonDnsServerAddresses
DuplicateAttributeException - Exception in io.servicetalk.client.api.partition: Indicates that a duplicate value was added while constructing a PartitionAttributes.
DuplicateAttributeException(PartitionAttributes.Key, String) - Constructor for exception io.servicetalk.client.api.partition.DuplicateAttributeException: Create a new instance.
DuplicateSubscribeException - Exception in io.servicetalk.concurrent.internal: Used in scenarios where a subscribe to an asynchronous source is subscribed to, but there is already a subscriber and the source doesn't support multiple subscribers.
DuplicateSubscribeException(Object, Object) - Constructor for exception io.servicetalk.concurrent.internal.DuplicateSubscribeException: Create a new instance.
DuplicateSubscribeException(Object, Object, String) - Constructor for exception io.servicetalk.concurrent.internal.DuplicateSubscribeException: Create a new instance.

E

EARLY_HINTS - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 103 Early Hints
earlyHints() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.EARLY_HINTS response.
earlyHints() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.EARLY_HINTS response.
earlyHints() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.EARLY_HINTS response.
effectiveHost() - Method in interface io.servicetalk.http.api.HttpRequestMetaData: The host component derived from HttpRequestMetaData.requestTarget() and the Host header field value.
effectivePort() - Method in interface io.servicetalk.http.api.HttpRequestMetaData: The port component derived from HttpRequestMetaData.requestTarget() and the Host header field value.
ElementsAreNonnullByDefault - Annotation Type in io.servicetalk.annotations: Indicates that fields, method parameters, method return types, and type parameters within a package are Nonnull unless explicitly annotated with Nullable.
empty() - Static method in class io.servicetalk.concurrent.api.Publisher: Creates a new Publisher that completes when subscribed without emitting any item to its PublisherSource.Subscriber.
EMPTY_BUFFER - Static variable in class io.servicetalk.buffer.api.EmptyBuffer: An instance of EmptyBuffer that can be shared.
EMPTY_SUBSCRIPTION - Static variable in class io.servicetalk.concurrent.internal.EmptySubscription
emptyAsciiString() - Static method in class io.servicetalk.http.api.CharSequences: Get a reference to an unmodifiable empty CharSequence with the same properties as CharSequences.newAsciiString(Buffer).
emptyAsyncCloseable() - Static method in class io.servicetalk.concurrent.api.AsyncCloseables: Creates an empty ListenableAsyncCloseable that does nothing when AsyncCloseable.closeAsync() apart from completing the ListenableAsyncCloseable.onClose().
emptyBlockingIterable() - Static method in class io.servicetalk.concurrent.internal.BlockingIterables: Get a BlockingIterable that generates BlockingIterators where Iterator.hasNext() returns true.
EmptyBuffer - Class in io.servicetalk.buffer.api: An immutable zero capacity Buffer.
EmptyHttpHeaders - Class in io.servicetalk.http.api: HttpHeaders which are always empty and does not allow modification.
EmptySubscription - Class in io.servicetalk.concurrent.internal: A PublisherSource.Subscription implementation, which does not do anything.
EmptySubscription() - Constructor for class io.servicetalk.concurrent.internal.EmptySubscription
enableFrameLogging(String) - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder: Enables a logger for HTTP/2 frames.
enableWireLogging(String) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
enableWireLogging(String) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Enable wire-logging for this server.
enableWireLogging(String) - Method in class io.servicetalk.http.api.HttpServerBuilder: Enables wire-logging for this server.
enableWireLogging(String) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
enableWireLogging(String) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
enableWireLogging(String) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
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(ZipkinPublisher.Encoder) - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher.Builder: Configures the format.
encoding() - Method in enum io.servicetalk.grpc.api.GrpcMessageEncoding: A string representation for the message encoding.
ensureThreadAffinity(Executor) - Static method in class io.servicetalk.concurrent.api.internal.OffloaderAwareExecutor: If the passed Executor does not honor thread affinity then return a new Executor that does honor thread affinity.
ensureWritable(int) - Method in interface io.servicetalk.buffer.api.Buffer: Expands the buffer Buffer.capacity() to make sure the number of writable bytes is equal to or greater than the specified value.
ensureWritable(int, boolean) - Method in interface io.servicetalk.buffer.api.Buffer: Expands the buffer Buffer.capacity() to make sure the number of writable bytes is equal to or greater than the specified value.
ensureWritable(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
ensureWritable(int, boolean) - Method in class io.servicetalk.buffer.api.EmptyBuffer
epochMicros() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog: Get the microseconds since epoch for this InMemorySpanLog.
equals(Object) - Method in interface io.servicetalk.buffer.api.Buffer: Determines if the content of the specified buffer is identical to the content of this array.
equals(Object) - Method in class io.servicetalk.client.api.DefaultGroupKey
equals(Object) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key
equals(Object) - Method in class io.servicetalk.grpc.api.GrpcStatus
equals(Object) - Method in class io.servicetalk.http.api.DefaultHttpCookiePair
equals(Object) - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
equals(Object) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
equals(Object) - Method in class io.servicetalk.http.api.HttpProtocolVersion
equals(Object) - Method in class io.servicetalk.http.api.HttpRequestMethod
equals(Object) - Method in class io.servicetalk.http.api.HttpRequestMethod.Properties
equals(Object) - Method in class io.servicetalk.http.api.HttpResponseStatus
equals(Object) - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
equals(Object) - Method in class io.servicetalk.transport.api.DefaultExecutionContext
equals(Object) - Method in class io.servicetalk.transport.api.DomainSocketAddress
equals(Object) - Method in class io.servicetalk.transport.api.FileDescriptorSocketAddress
error(Throwable) - Static method in class io.servicetalk.concurrent.internal.TerminalNotification: Returns a TerminalNotification for cause.
ETAG - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "etag"
event() - Method in interface io.servicetalk.client.api.ConsumableEvent: Get the event.
event() - Method in class io.servicetalk.client.api.internal.IgnoreConsumedEvent
event() - Method in exception io.servicetalk.transport.netty.internal.CloseHandler.CloseEventObservedException: CloseHandler.CloseEvent was observed from the protocol or Channel.
eventConsumed() - Method in interface io.servicetalk.client.api.ConsumableEvent: Signify the ConsumableEvent.event() has been consumed and any side effects have taken place.
eventConsumed() - Method in class io.servicetalk.client.api.internal.IgnoreConsumedEvent
EventLoopAwareNettyIoExecutor - Interface in io.servicetalk.transport.netty.internal: A special NettyIoExecutor that exposes the underlying netty EventLoopGroup.
EventLoopAwareNettyIoExecutors - Class in io.servicetalk.transport.netty.internal: A static factory to create or convert to EventLoopAwareNettyIoExecutor.
eventLoopGroup() - Method in interface io.servicetalk.transport.netty.internal.EventLoopAwareNettyIoExecutor: Returns the underlying EventLoopGroup.
eventName() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog: Get the name of the event for this InMemorySpanLog.
eventStream() - Method in interface io.servicetalk.client.api.LoadBalancer: A Publisher of events provided by this LoadBalancer.
eventStream() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancer
execute(Runnable) - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
execute(Runnable) - Method in class io.servicetalk.concurrent.api.internal.OffloaderAwareExecutor
execute(Runnable) - Method in interface io.servicetalk.concurrent.Executor: Executes the passed task as soon as possible.
execute(T) - Method in class io.servicetalk.transport.netty.internal.SequentialTaskQueue: Executes the passed task and call SequentialTaskQueue.postTaskTermination() when the task has finished execution, synchronously or asynchronously.
executeExclusive(Runnable, AtomicIntegerFieldUpdater<T>, T) - Static method in class io.servicetalk.concurrent.internal.ConcurrentUtils: Executes the passed Runnable assuring that concurrent invocations of this method does not concurrently execute the Runnable.
executionContext() - Method in class io.servicetalk.client.api.DefaultGroupKey
executionContext() - Method in interface io.servicetalk.client.api.GroupKey: Get the ExecutionContext to use when looking for or creating a new client.
executionContext() - Method in interface io.servicetalk.grpc.api.BlockingGrpcClient: Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.FilterableGrpcClient: Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.GrpcClient: Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.GrpcClientCallFactory: Get the GrpcExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.grpc.api.GrpcServiceContext
executionContext() - Method in interface io.servicetalk.http.api.BlockingHttpRequester: Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequester: Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in class io.servicetalk.http.api.DelegatingHttpConnectionContext
executionContext() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
executionContext() - Method in interface io.servicetalk.http.api.HttpConnectionContext
executionContext() - Method in interface io.servicetalk.http.api.HttpRequester: Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
executionContext() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
executionContext() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
executionContext() - Method in interface io.servicetalk.http.api.StreamingHttpRequester: Get the HttpExecutionContext used during construction of this object.
executionContext() - Method in interface io.servicetalk.transport.api.ConnectionContext: Get the ExecutionContext for this ConnectionContext.
executionContext() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
ExecutionContext - Interface in io.servicetalk.transport.api: Context related to execution and allocation.
executionContext() - Method in interface io.servicetalk.transport.api.ServerContext: Returns ExecutionContext used by this server.
executionContext() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
executionContext() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection
executionContext() - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
ExecutionContextBuilder - Class in io.servicetalk.transport.netty.internal: A builder of ExecutionContext.
ExecutionContextBuilder() - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: New instance.
ExecutionContextBuilder(ExecutionContextBuilder) - Constructor for class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Copy constructor.
executionStrategy(GrpcExecutionStrategy) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
executionStrategy() - Method in interface io.servicetalk.grpc.api.GrpcExecutionContext: Returns the GrpcExecutionStrategy associated with this context.
executionStrategy(GrpcExecutionStrategy) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Sets the HttpExecutionStrategy to be used by this server.
executionStrategy() - Method in class io.servicetalk.http.api.DefaultHttpExecutionContext
executionStrategy() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
executionStrategy() - Method in interface io.servicetalk.http.api.HttpExecutionContext: Returns the HttpExecutionStrategy associated with this context.
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.HttpServerBuilder: Sets the HttpExecutionStrategy to be used by this server.
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
executionStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
executionStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation: Specifies an HttpExecutionStrategy to be used for this route.
executionStrategy() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
executionStrategy() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
executionStrategy() - Method in interface io.servicetalk.transport.api.ExecutionContext: Returns the ExecutionStrategy associated with this context.
ExecutionStrategy - Interface in io.servicetalk.transport.api: An execution strategy for all transports.
executionStrategy(ExecutionStrategy) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Sets the ExecutionStrategy to use.
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.
executor(Executor) - Method in class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder: Specify an Executor to use.
executor() - Method in class io.servicetalk.http.api.DefaultHttpExecutionContext
executor() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
executor(Executor) - Method in class io.servicetalk.http.api.HttpExecutionStrategies.Builder: Specify an Executor to use.
executor() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
executor() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
executor() - Method in interface io.servicetalk.transport.api.ExecutionContext: Get the Executor that is used to create any asynchronous sources.
executor() - Method in interface io.servicetalk.transport.api.ExecutionStrategy: Returns the Executor, if any for this ExecutionStrategy.
executor(Executor) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Sets the Executor to use.
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.
expires() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
EXPIRES - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "expires"
expires() - Method in interface io.servicetalk.http.api.HttpSetCookie: Returns the expire date of this HttpSetCookie according to Expires.
extract(Format<C>, C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
extract(C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTraceStateFormat: Extract the trace state from a carrier.
extract(SingleLineValue) - Method in class io.servicetalk.opentracing.inmemory.SingleLineFormatter
extractByteBufOrCreate(Buffer) - Static method in class io.servicetalk.buffer.netty.BufferUtils: Converts the passed buffer to ByteBuf, creating a new ByteBuf instance if required.
extractSslSession(ChannelPipeline, SslHandshakeCompletionEvent, Consumer<Throwable>) - Static method in class io.servicetalk.transport.netty.internal.NettyPipelineSslUtils: Extract the SSLSession from the ChannelPipeline if the SslHandshakeCompletionEvent is successful.

F

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

G

GATEWAY_TIMEOUT - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 504 Gateway Timeout
gatewayTimeout() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.GATEWAY_TIMEOUT response.
gatewayTimeout() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.GATEWAY_TIMEOUT response.
gatewayTimeout() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.GATEWAY_TIMEOUT response.
get(Key) - Method in interface io.servicetalk.client.api.ClientGroup: Return the Client identified by the provided key or create a new one when none exists.
get(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
get(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
get(PartitionAttributes.Key<T>) - Method in interface io.servicetalk.client.api.partition.PartitionAttributes: Get the value associated with key.
get(PartitionAttributes) - Method in interface io.servicetalk.client.api.partition.PartitionMap: Get the partition value corresponding to the PartitionAttributes parameter.
get(AsyncContextMap.Key<T>) - Static method in class io.servicetalk.concurrent.api.AsyncContext: Convenience method to get the value associated with key from the current context.
get(AsyncContextMap.Key<T>) - Method in interface io.servicetalk.concurrent.api.AsyncContextMap: Get the value associated with key, or null if no value is associated.
get(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory: Create a new HttpRequestMethod.GET request.
get(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
get(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
get(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Returns the value of a header with the specified name.
get(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Returns the value of a header with the specified name.
get(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory: Create a new HttpRequestMethod.GET request.
GET - Static variable in class io.servicetalk.http.api.HttpRequestMethod: HTTP GET method.
get(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory: Create a new HttpRequestMethod.GET request.
get(String) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
get() - Method in interface io.servicetalk.opentracing.inmemory.SingleLineValue: Gets the value.
get(String) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
get(String) - Method in interface io.servicetalk.router.api.RouteExecutionStrategyFactory: Gets an execution strategy for the specified idid of RouteExecutionStrategy annotation.
get(String) - Method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory
getAndRemove(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getAndRemove(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Returns the value of a header with the specified name and removes it from this object.
getAndRemove(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Returns the value of a header with the specified name and removes it from this object.
getAndValidateRouteExecutionStrategyAnnotationIfPresent(Method, Class<?>, RouteExecutionStrategyFactory<T>, Set<String>, T) - Static method in class io.servicetalk.router.utils.internal.RouteExecutionStrategyUtils: Returns ExecutionStrategy for the specified Method and validates that configuration of RouteExecutionStrategy annotation is correct if present.
getAuthenticationScheme() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
getBaseRequestUri(ConnectionContext, HttpRequestMetaData, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils: Get the base URI for the provided ConnectionContext and HttpRequestMetaData.
getBaseRequestUri(ConnectionContext, HttpRequestMetaData, String, String, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils: Get the base URI for the provided ConnectionContext and HttpRequestMetaData.
getBoolean(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a boolean at the specified absolute (@code index) in this buffer.
getBoolean(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getByte(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a byte at the specified absolute index in this buffer.
getByte(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getByteBufAllocator(BufferAllocator) - Static method in class io.servicetalk.buffer.netty.BufferUtils: Returns the ByteBufAllocator taking the BufferAllocator into account.
getBytes(int, Buffer) - Method in interface io.servicetalk.buffer.api.Buffer: Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination becomes non-writable.
getBytes(int, Buffer, int) - Method in interface io.servicetalk.buffer.api.Buffer: Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, Buffer, int, int) - Method in interface io.servicetalk.buffer.api.Buffer: Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, byte[]) - Method in interface io.servicetalk.buffer.api.Buffer: Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, byte[], int, int) - Method in interface io.servicetalk.buffer.api.Buffer: Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, ByteBuffer) - Method in interface io.servicetalk.buffer.api.Buffer: Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit.
getBytes(int, Buffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
getBytes(int, Buffer, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
getBytes(int, Buffer, int, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
getBytes(int, byte[]) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
getBytes(int, byte[], int, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
getBytes(int, ByteBuffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
getBytes(int, Buffer) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getBytes(int, Buffer, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getBytes(int, Buffer, int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getBytes(int, byte[]) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getBytes(int, byte[], int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getBytes(int, ByteBuffer) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getChar(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 2-byte UTF-16 character at the specified absolute index in this buffer.
getChar(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getCookie(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getCookie(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets a cookie identified by name.
getCookies() - Method in interface io.servicetalk.http.api.HttpHeaders: Gets all the cookies.
getCookies(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets the cookies with the same name.
getCookiesIterator() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getCookiesIterator(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getCookiesIterator() - Method in interface io.servicetalk.http.api.HttpHeaders: Gets all the cookies.
getCookiesIterator(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets the cookies with the same name.
getCopy() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
getCopy(Map<String, String>) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap: Get a copy of this ThreadContextMap given the underlying Map storage.
getCopy(Map<String, String>) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
getDeserializer(Class<T>) - Method in class io.servicetalk.data.jackson.JacksonSerializationProvider
getDeserializer(TypeHolder<T>) - Method in class io.servicetalk.data.jackson.JacksonSerializationProvider
getDeserializer(Class<T>) - Method in class io.servicetalk.data.protobuf.ProtobufSerializationProvider
getDeserializer(TypeHolder<T>) - Method in class io.servicetalk.data.protobuf.ProtobufSerializationProvider
getDeserializer(Class<T>) - Method in interface io.servicetalk.serialization.api.SerializationProvider: Provide a StreamingDeserializer instance that can deserialize instances of T.
getDeserializer(TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.SerializationProvider: Provide a StreamingDeserializer instance that can deserialize instances of T.
getDouble(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 64-bit floating point number at the specified absolute index in this buffer.
getDouble(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getEffectiveRequestUri(ConnectionContext, HttpRequestMetaData, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils: Get the effective request URI for the provided ConnectionContext and HttpRequestMetaData.
getEffectiveRequestUri(ConnectionContext, HttpRequestMetaData, String, String, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils: Get the effective request URI for the provided ConnectionContext and HttpRequestMetaData.
getEffectiveRequestUri(HttpRequestMetaData, String, String, boolean) - Static method in class io.servicetalk.http.utils.HttpRequestUriUtils: Get the effective request URI for the provided HttpRequestMetaData.
getFloat(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 32-bit floating point number at the specified absolute index in this buffer.
getFloat(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getImmutableMapOrNull() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
getImmutableMapOrNull(Map<String, String>) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap: Provide the implementation for ServiceTalkThreadContextMap.getImmutableMapOrNull() given then underlying Map storage.
getImmutableMapOrNull(Map<String, String>) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
getInt(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 32-bit integer at the specified absolute index in this buffer.
getInt(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getIntLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 32-bit integer at the specified absolute index in this buffer with Little Endian Byte Order.
getIntLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getKey() - Method in exception io.servicetalk.client.api.partition.DuplicateAttributeException: Get the PartitionAttributes.Key which corresponds to the exception.
getLong(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 64-bit long integer at the specified absolute index in this buffer.
getLong(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getLongLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 64-bit long integer at the specified absolute index in this buffer in Little Endian Byte Order.
getLongLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getMedium(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 24-bit medium integer at the specified absolute index in this buffer.
getMedium(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getMediumLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 24-bit medium integer at the specified absolute index in this buffer in the Little Endian Byte Order.
getMediumLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getMessage() - Method in exception io.servicetalk.transport.netty.internal.CloseHandler.CloseEventObservedException
getName() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
getOperationName(String, HttpRequestMetaData) - Method in class io.servicetalk.opentracing.http.TracingHttpServiceFilter: Get the operation name to build the span with.
getOption(SocketOption<T>, ChannelConfig, Long) - Static method in class io.servicetalk.transport.netty.internal.SocketOptionUtils: Get a SocketOption value from ChannelConfig.
getPartitionSelector() - Method in exception io.servicetalk.client.api.partition.ClosedPartitionException: Get the PartitionAttributes that was used to select the partition.
getPartitionSelector() - Method in exception io.servicetalk.client.api.partition.UnknownPartitionException: Get the PartitionAttributes that was used to select the partition.
getPath() - Method in class io.servicetalk.transport.api.DomainSocketAddress: The file system path used to bind/connect for a UNIX domain socket.
getReadOnlyContextData() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
getReadOnlyContextData(Map<String, String>) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap: Create a new read-only StringMap.
getReadOnlyContextData(Map<String, String>) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
getRequestBufferPublisherInputStream(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties: Get the BufferPublisherInputStream associated with the request.
getRequestCancellable(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties: Get the request Cancellable.
getResponseBufferPublisher(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties: Get the response Publisher<Buffer>.
getResponseExecutionStrategy(ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties: Get the response HttpExecutionStrategy used for offloading.
getRouteExecutionStrategyAnnotation(Method, Class<?>) - Static method in class io.servicetalk.router.utils.internal.RouteExecutionStrategyUtils: Returns RouteExecutionStrategy annotation if exists on Method or Class.
getSerializer(Class<T>) - Method in class io.servicetalk.data.jackson.JacksonSerializationProvider
getSerializer(TypeHolder<T>) - Method in class io.servicetalk.data.jackson.JacksonSerializationProvider
getSerializer(Class<T>) - Method in class io.servicetalk.data.protobuf.ProtobufSerializationProvider
getSerializer(TypeHolder<T>) - Method in class io.servicetalk.data.protobuf.ProtobufSerializationProvider
getSerializer(Class<T>) - Method in interface io.servicetalk.serialization.api.SerializationProvider: Provide a StreamingSerializer instance that can serialize instances of T.
getSerializer(TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.SerializationProvider: Provide a StreamingSerializer instance that can serialize instances of T.
getSetCookie(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getSetCookie(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets a set-cookie identified by name.
getSetCookies() - Method in interface io.servicetalk.http.api.HttpHeaders: Gets all the set-cookies.
getSetCookies(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets the set-cookies with the same name.
getSetCookies(CharSequence, CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets the set-cookies with the same name.
getSetCookiesIterator() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getSetCookiesIterator(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getSetCookiesIterator(CharSequence, CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
getSetCookiesIterator() - Method in interface io.servicetalk.http.api.HttpHeaders: Gets all the set-cookies.
getSetCookiesIterator(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets the set-cookies with the same name.
getSetCookiesIterator(CharSequence, CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders: Gets the set-cookies with the same name.
getShort(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 16-bit short integer at the specified absolute index in this buffer.
getShort(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getShortLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets a 16-bit short integer at the specified absolute index in this buffer in Little Endian Byte Order.
getShortLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getSystemId() - Method in class io.servicetalk.http.router.jersey.internal.SourceWrappers.PublisherSource
getSystemId() - Method in class io.servicetalk.http.router.jersey.internal.SourceWrappers.SingleSource
getUnsignedByte(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned byte at the specified absolute index in this buffer.
getUnsignedByte(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUnsignedInt(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned 32-bit integer at the specified absolute index in this buffer.
getUnsignedInt(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUnsignedIntLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned 32-bit integer at the specified absolute index in this buffer in Little Endian Byte Order.
getUnsignedIntLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUnsignedMedium(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned 24-bit medium integer at the specified absolute index in this buffer.
getUnsignedMedium(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUnsignedMediumLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned 24-bit medium integer at the specified absolute index in this buffer in Little Endian Byte Order.
getUnsignedMediumLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUnsignedShort(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned 16-bit short integer at the specified absolute index in this buffer.
getUnsignedShort(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUnsignedShortLE(int) - Method in interface io.servicetalk.buffer.api.Buffer: Gets an unsigned 16-bit short integer at the specified absolute index in this buffer in Little Endian Byte Order.
getUnsignedShortLE(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
getUserPrincipal() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
getUsingDefaultStrategyFactory(String) - Static method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory: Returns an ES provided by DefaultRouteExecutionStrategyFactory.defaultStrategyFactory().
getValue() - Method in class io.servicetalk.transport.api.FileDescriptorSocketAddress: Return the filedescriptor value.
GlobalExecutionContext - Class in io.servicetalk.transport.netty.internal: ServiceTalk's shared ExecutionContext with reasonable defaults for APIs when a user doesn't provide one.
globalExecutionContext() - Static method in class io.servicetalk.transport.netty.internal.GlobalExecutionContext: Get the GlobalExecutionContext.
gone() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.GONE response.
gone() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.GONE response.
GONE - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 410 Gone
gone() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.GONE response.
GracefulAutoCloseable - Interface in io.servicetalk.concurrent: An extension of AutoCloseable to add graceful closure semantics.
groupBy(Function<? super T, ? extends Key>, int) - Method in class io.servicetalk.concurrent.api.Publisher: Splits items from this Publisher into dynamically generated GroupedPublishers.
groupBy(Function<? super T, ? extends Key>, int, int) - Method in class io.servicetalk.concurrent.api.Publisher: Splits items from this Publisher into dynamically generated GroupedPublishers.
GroupedPublisher<Key,T> - Class in io.servicetalk.concurrent.api: A group as emitted by Publisher.groupBy(Function, int) or its variants.
GroupedPublisher.QueueSizeProvider - Interface in io.servicetalk.concurrent.api: Provide the maximum queue size to use for a particular GroupedPublisher key.
GroupKey<Address> - Interface in io.servicetalk.client.api: Identifies a client within a group of clients, and provides enough information to create a client if non exist.
groupToMany(Function<? super T, ? extends Iterator<? extends Key>>, int) - Method in class io.servicetalk.concurrent.api.Publisher: The semantics are identical to Publisher.groupBy(Function, int) except that the keySelector can map each data to multiple keys.
groupToMany(Function<? super T, ? extends Iterator<? extends Key>>, int, int) - Method in class io.servicetalk.concurrent.api.Publisher: The semantics are identical to Publisher.groupBy(Function, int) except that the keySelector can map each data to multiple keys.
GrpcClient<BlockingClient extends BlockingGrpcClient> - Interface in io.servicetalk.grpc.api: A client to a gRPC service.
GrpcClientBuilder<U,R> - Class in io.servicetalk.grpc.api: A builder for building a gRPC client.
GrpcClientBuilder() - Constructor for class io.servicetalk.grpc.api.GrpcClientBuilder
GrpcClientBuilder.MultiClientBuilder - Interface in io.servicetalk.grpc.api: An interface to create multiple gRPC clients sharing the same underlying transport instance.
GrpcClientCallFactory - Interface in io.servicetalk.grpc.api: A factory to create gRPC client call objects for different programming models.
GrpcClientCallFactory.BlockingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make blocking client calls.
GrpcClientCallFactory.BlockingRequestStreamingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make blocking client calls where request is streaming.
GrpcClientCallFactory.BlockingResponseStreamingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make blocking client calls where response is streaming.
GrpcClientCallFactory.BlockingStreamingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make blocking bi-directional streaming client calls.
GrpcClientCallFactory.ClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make asynchronous client calls.
GrpcClientCallFactory.RequestStreamingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make asynchronous client calls where request is streaming.
GrpcClientCallFactory.ResponseStreamingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make asynchronous client calls where response is streaming.
GrpcClientCallFactory.StreamingClientCall<Req,Resp> - Interface in io.servicetalk.grpc.api: An abstraction to make asynchronous bi-directional streaming client calls.
GrpcClientFactory<Client extends GrpcClient<BlockingClient>,BlockingClient extends BlockingGrpcClient<Client>,Filter extends FilterableClient,FilterableClient extends FilterableGrpcClient,FilterFactory extends GrpcClientFilterFactory<Filter,FilterableClient>> - Class in io.servicetalk.grpc.api: A factory for creating clients that follows the specified gRPC Client contract.
GrpcClientFactory() - Constructor for class io.servicetalk.grpc.api.GrpcClientFactory
GrpcClientFilterFactory<Filter extends FilterableClient,FilterableClient extends FilterableGrpcClient> - Interface in io.servicetalk.grpc.api: A factory to create gRPC client filters.
GrpcClientMetadata - Interface in io.servicetalk.grpc.api: Metadata for a gRPC client call.
GrpcClients - Class in io.servicetalk.grpc.netty: A factory to create gRPC clients.
GrpcClientSecurityConfigurator<U,R> - Interface in io.servicetalk.grpc.api: A ClientSecurityConfigurator for SingleAddressGrpcClientBuilder.
GrpcExecutionContext - Interface in io.servicetalk.grpc.api: An extension of ExecutionContext for gRPC.
GrpcExecutionStrategies - Class in io.servicetalk.grpc.api: A factory to create different GrpcExecutionStrategy.
GrpcExecutionStrategies.Builder - Class in io.servicetalk.grpc.api: A builder to build an HttpExecutionStrategy.
GrpcExecutionStrategy - Interface in io.servicetalk.grpc.api: An execution strategy for gRPC client and servers.
GrpcMessageEncoding - Enum in io.servicetalk.grpc.api: Supported gRPC message encoding schemes.
GrpcMetadata - Interface in io.servicetalk.grpc.api: Metadata for a gRPC call.
GrpcPayloadWriter<T> - Interface in io.servicetalk.grpc.api: A PayloadWriter for gRPC.
GrpcRoutes<Service extends GrpcService> - Class in io.servicetalk.grpc.api: A holder of gRPC routes that constitutes a service.
GrpcRoutes() - Constructor for class io.servicetalk.grpc.api.GrpcRoutes: Create a new instance.
GrpcRoutes(RouteExecutionStrategyFactory<GrpcExecutionStrategy>) - Constructor for class io.servicetalk.grpc.api.GrpcRoutes: Create new instance.
GrpcRoutes.AllGrpcRoutes - Interface in io.servicetalk.grpc.api: A collection of route corresponding to the enclosing GrpcRoutes.
GrpcRoutes.BlockingRequestStreamingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: A blocking gRPC route with request streaming.
GrpcRoutes.BlockingResponseStreamingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: A blocking gRPC route with response streaming.
GrpcRoutes.BlockingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: A blocking gRPC route.
GrpcRoutes.BlockingStreamingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: A blocking gRPC route with bi-directional streaming.
GrpcRoutes.RequestStreamingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: An asynchronous gRPC route with request streaming.
GrpcRoutes.ResponseStreamingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: An asynchronous gRPC route with response streaming.
GrpcRoutes.Route<Req,Resp> - Interface in io.servicetalk.grpc.api: An asynchronous gRPC route.
GrpcRoutes.StreamingRoute<Req,Resp> - Interface in io.servicetalk.grpc.api: An asynchronous gRPC route with bi-directional streaming.
GrpcSerializationProvider - Interface in io.servicetalk.grpc.api: A provider for gRPC serialization/deserialization.
GrpcServerBuilder - Class in io.servicetalk.grpc.api: A builder for building a gRPC server.
GrpcServerBuilder() - Constructor for class io.servicetalk.grpc.api.GrpcServerBuilder
GrpcServers - Class in io.servicetalk.grpc.netty: A factory to create gRPC servers.
GrpcServerSecurityConfigurator - Interface in io.servicetalk.grpc.api: A ServerSecurityConfigurator for GrpcServerBuilder.
GrpcService - Interface in io.servicetalk.grpc.api: A gRPC service.
GrpcServiceContext - Interface in io.servicetalk.grpc.api: A gRPC service context.
GrpcServiceContext.GrpcProtocol - Interface in io.servicetalk.grpc.api
GrpcServiceFactory<Filter extends Service,Service extends GrpcService,FilterFactory extends GrpcServiceFilterFactory<Filter,Service>> - Class in io.servicetalk.grpc.api: A factory for binding a gRPC service to a server using a GrpcServiceFactory.ServerBinder.
GrpcServiceFactory(GrpcRoutes<Service>) - Constructor for class io.servicetalk.grpc.api.GrpcServiceFactory: Creates new instance.
GrpcServiceFactory.ServerBinder - Interface in io.servicetalk.grpc.api: A utility to bind an HTTP service for gRPC with an appropriate programming model.
GrpcServiceFilterFactory<Filter extends Service,Service> - Interface in io.servicetalk.grpc.api: A factory to create gRPC service filters.
GrpcStatus - Class in io.servicetalk.grpc.api: Class representing gRPC statuses.
GrpcStatus(GrpcStatusCode) - Constructor for class io.servicetalk.grpc.api.GrpcStatus: Constructs a status with no cause or description.
GrpcStatus(GrpcStatusCode, Throwable) - Constructor for class io.servicetalk.grpc.api.GrpcStatus: Constructs a status with cause but no additional description.
GrpcStatus(GrpcStatusCode, Throwable, CharSequence) - Constructor for class io.servicetalk.grpc.api.GrpcStatus: Constructs a status with cause and additional description.
GrpcStatusCode - Enum in io.servicetalk.grpc.api: Standard gRPC status codes.
GrpcStatusException - Exception in io.servicetalk.grpc.api: A GrpcStatus in exception form.
GZIP - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "gzip"

H

h1() - Static method in class io.servicetalk.http.netty.HttpProtocolConfigs: Returns a builder for H1ProtocolConfig.
h1Default() - Static method in class io.servicetalk.http.netty.HttpProtocolConfigs: Returns H1ProtocolConfig with the default configuration for HTTP/1.1.
H1ProtocolConfig - Interface in io.servicetalk.http.netty: Configuration for HTTP/1.1 protocol.
H1ProtocolConfigBuilder - Class in io.servicetalk.http.netty: Builder for H1ProtocolConfig.
h2() - Static method in class io.servicetalk.http.netty.HttpProtocolConfigs: Returns a builder for H2ProtocolConfig.
h2Default() - Static method in class io.servicetalk.http.netty.HttpProtocolConfigs: Returns H2ProtocolConfig with the default configuration for HTTP/2.
H2HeadersFactory - Class in io.servicetalk.http.netty: A HttpHeadersFactory optimized for HTTP/2.
H2HeadersFactory(boolean, boolean) - Constructor for class io.servicetalk.http.netty.H2HeadersFactory: Create an instance of the factory with the default array size hint.
H2HeadersFactory(boolean, boolean, int, int) - Constructor for class io.servicetalk.http.netty.H2HeadersFactory: Create an instance of the factory.
H2ProtocolConfig - Interface in io.servicetalk.http.netty: Configuration for HTTP/2 protocol.
H2ProtocolConfigBuilder - Class in io.servicetalk.http.netty: Builder for H2ProtocolConfig.
handle(GrpcServiceContext, BlockingIterable<Req>) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingRequestStreamingRoute: Handles the passed Req.
handle(GrpcServiceContext, Req, GrpcPayloadWriter<Resp>) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingResponseStreamingRoute: Handles the passed Req.
handle(GrpcServiceContext, Req) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingRoute: Handles the passed Req.
handle(GrpcServiceContext, BlockingIterable<Req>, GrpcPayloadWriter<Resp>) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingStreamingRoute: Handles the passed Req.
handle(GrpcServiceContext, Publisher<Req>) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.RequestStreamingRoute: Handles the passed Req.
handle(GrpcServiceContext, Req) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.ResponseStreamingRoute: Handles the passed Req.
handle(GrpcServiceContext, Req) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.Route: Handles the passed Req.
handle(GrpcServiceContext, Publisher<Req>) - Method in interface io.servicetalk.grpc.api.GrpcRoutes.StreamingRoute: Handles the passed Req.
handle(HttpServiceContext, HttpRequest, HttpResponseFactory) - Method in interface io.servicetalk.http.api.BlockingHttpService: Handles a single HTTP request.
handle(HttpServiceContext, BlockingStreamingHttpRequest, BlockingStreamingHttpServerResponse) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpService: Handles a single HTTP request.
handle(HttpServiceContext, HttpRequest, HttpResponseFactory) - Method in interface io.servicetalk.http.api.HttpService: Handles a single HTTP request.
handle(HttpServiceContext, StreamingHttpRequest, StreamingHttpResponseFactory) - Method in interface io.servicetalk.http.api.StreamingHttpService: Handles a single HTTP request.
handle(HttpServiceContext, StreamingHttpRequest, StreamingHttpResponseFactory) - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
handleEntityStream(InputStream, BufferAllocator, BiFunction<Publisher<Buffer>, BufferAllocator, T>, BiFunction<InputStream, BufferAllocator, T>) - Static method in class io.servicetalk.http.router.jersey.internal.BufferPublisherInputStream: Helper method for dealing with a request entity InputStream that is potentially a BufferPublisherInputStream.
handleExceptionFromOnSubscribe(PublisherSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils: Handle the case when a call to PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) throws from a source.
handleExceptionFromOnSubscribe(SingleSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils: Handle the case when a call to SingleSource.Subscriber#onSubscribe(Cancellable) throws from a source.
handleExceptionFromOnSubscribe(CompletableSource.Subscriber, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils: Handle the case when a call to CompletableSource.Subscriber#onSubscribe(Cancellable) throws from a source.
handlerRemoved(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
handlerRemoved0(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder: Gets called after the ByteToMessageDecoder was removed from the actual context and it doesn't handle events anymore.
handleSubscribe(CompletableSource.Subscriber) - Method in class io.servicetalk.concurrent.api.Completable: Handles a subscriber to this Completable.
handleSubscribe(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.internal.SpScPublisherProcessor
handleSubscribe(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher: Handles a subscriber to this Publisher.
handleSubscribe(SingleSource.Subscriber<? super T>) - Method in class io.servicetalk.concurrent.api.Single: Handles a subscriber to this Single.
handleSubscribe(PublisherSource.Subscriber<? super T>) - Method in class io.servicetalk.http.router.jersey.internal.SourceWrappers.PublisherSource
handleSubscribe(SingleSource.Subscriber<? super T>) - Method in class io.servicetalk.http.router.jersey.internal.SourceWrappers.SingleSource
hasArray() - Method in interface io.servicetalk.buffer.api.Buffer: Returns true if and only if this buffer has a backing byte array.
hasArray() - Method in class io.servicetalk.buffer.api.EmptyBuffer
hasData() - Method in interface io.servicetalk.serialization.api.StreamingDeserializer: Returns true if this StreamingDeserializer contains any data from a previous invocation of StreamingDeserializer.deserialize(Buffer) that has not yet been deserialized.
hashCode() - Method in interface io.servicetalk.buffer.api.Buffer: Returns a hash code which was calculated from the content of this buffer.
hashCode() - Method in class io.servicetalk.client.api.DefaultGroupKey
hashCode() - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key
hashCode() - Method in class io.servicetalk.grpc.api.GrpcStatus
hashCode() - Method in class io.servicetalk.http.api.DefaultHttpCookiePair
hashCode() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
hashCode() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
hashCode() - Method in class io.servicetalk.http.api.HttpProtocolVersion
hashCode() - Method in class io.servicetalk.http.api.HttpRequestMethod
hashCode() - Method in class io.servicetalk.http.api.HttpRequestMethod.Properties
hashCode() - Method in class io.servicetalk.http.api.HttpResponseStatus
hashCode() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
hashCode() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
hashCode() - Method in class io.servicetalk.transport.api.DomainSocketAddress
hashCode() - Method in class io.servicetalk.transport.api.FileDescriptorSocketAddress
hasLeftOver() - Method in class io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream
hasLeftOver() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream: Determine if there are left over bytes buffered.
hasNext(long, TimeUnit) - Method in interface io.servicetalk.concurrent.BlockingIterator: The equivalent of Iterator.hasNext() but only waits for timeout duration amount of time.
hasNext() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
hasNext() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator
hasQueryParameter(String) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Returns true if a query parameter with the key exists, false otherwise.
hasQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequestMetaData: Returns true if a query parameter with the key and value exists, false otherwise.
hasThreadAffinity() - Method in class io.servicetalk.concurrent.api.internal.OffloaderAwareExecutor
hasThreadAffinity() - Method in interface io.servicetalk.concurrent.internal.SignalOffloaderFactory: Returns true if and only if all SignalOffloader instances will always provide thread affinity.
hasThreadAffinity(Executor) - Static method in class io.servicetalk.concurrent.internal.SignalOffloaders: Returns true if the passed Executor honors thread affinity.
hasUnsafe() - Static method in class io.servicetalk.utils.internal.PlatformDependent: Checks if sun.misc.Unsafe is available and has not been disabled.
head(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory: Create a new HttpRequestMethod.HEAD request.
head(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory: Create a new HttpRequestMethod.HEAD request.
HEAD - Static variable in class io.servicetalk.http.api.HttpRequestMethod: HTTP HEAD method.
head(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory: Create a new HttpRequestMethod.HEAD request.
headers() - Method in interface io.servicetalk.http.api.HttpMetaData: Returns the headers of this message.
headersEncodedSizeEstimate() - Method in interface io.servicetalk.http.netty.H1ProtocolConfig: Value used to calculate an exponential moving average of the encoded size of the HTTP start line and header fields for a guess for future buffer allocations.
headersEncodedSizeEstimate(int) - Method in class io.servicetalk.http.netty.H1ProtocolConfigBuilder: Sets the value used to calculate an exponential moving average of the encoded size of the HTTP start line and header fields for a guess for future buffer allocations.
headersFactory() - Method in interface io.servicetalk.http.api.HttpProtocolConfig: HttpHeadersFactory to be used for creating HttpHeaders when decoding HTTP messages.
headersFactory() - Method in class io.servicetalk.http.api.HttpServiceContext: Returns the HttpHeadersFactory associated with this HttpServiceContext.
headersFactory(HttpHeadersFactory) - Method in class io.servicetalk.http.netty.H1ProtocolConfigBuilder: Sets the HttpHeadersFactory to be used for creating HttpHeaders when decoding HTTP messages.
headersFactory(HttpHeadersFactory) - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder: Sets the HttpHeadersFactory to be used for creating HttpHeaders when decoding HTTP messages.
headersSensitivityDetector() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig: Sensitivity detector to determine if a header name/value pair should be treated as sensitive.
headersSensitivityDetector(BiPredicate<CharSequence, CharSequence>) - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder: Sets the sensitivity detector to determine if a header name/value pair should be treated as sensitive.
HeaderUtils - Class in io.servicetalk.http.api: Utilities to use for HttpHeaders implementations.
HeaderUtils.CookiesByNameIterator - Class in io.servicetalk.http.api: An Iterator of HttpCookiePair designed to iterate across multiple values of HttpHeaderNames.COOKIE for a specific cookie-name.
HeaderUtils.CookiesIterator - Class in io.servicetalk.http.api: An Iterator of HttpCookiePair designed to iterate across multiple values of HttpHeaderNames.COOKIE.
hexBytesOfLong(long) - Static method in class io.servicetalk.opentracing.internal.HexUtils: Builds an hex String that represents the provided long value.
HexUtils - Class in io.servicetalk.opentracing.internal: Utilities for hex strings.
HOST - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "host"
host() - Method in interface io.servicetalk.http.api.HttpRequestMetaData: The host component derived from HttpRequestMetaData.requestTarget().
HostAndPort - Interface in io.servicetalk.transport.api: A tuple of <host name, port>.
hostName() - Method in interface io.servicetalk.transport.api.HostAndPort: Returns the host name.
hostnameVerification(String, String) - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
hostnameVerification(String, String, int) - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
hostnameVerification(String) - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
hostnameVerification(String, int) - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
hostnameVerification(String, String) - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
hostnameVerification(String, String, int) - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
hostnameVerification(String) - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
hostnameVerification(String, int) - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
hostnameVerification(String, String) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
hostnameVerification(String, String, int) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
hostnameVerification(String) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
hostnameVerification(String, int) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
hostnameVerification(String, String) - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator: Determines what algorithm to use for hostname verification.
hostnameVerification(String, String, int) - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator: Determines what algorithm to use for hostname verification.
hostnameVerification(String) - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator: Set the host name used to verify the server identity.
hostnameVerification(String, int) - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator: Set the host name and port used to verify the server identity.
hostNameVerification(String, String) - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Determines what algorithm to use for hostname verification.
hostNameVerification(String, String, int) - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Determines what algorithm to use for hostname verification.
hostNameVerification(String) - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Set the host name used to verify the server identity.
hostNameVerification(String, int) - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Set the host name and port used to verify the server identity.
hostnameVerificationAlgorithm(String) - Method in interface io.servicetalk.grpc.api.GrpcClientSecurityConfigurator
hostnameVerificationAlgorithm(String) - Method in interface io.servicetalk.http.api.PartitionedHttpClientSecurityConfigurator
hostnameVerificationAlgorithm(String) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientSecurityConfigurator
hostnameVerificationAlgorithm(String) - Method in interface io.servicetalk.transport.api.ClientSecurityConfigurator: Determines what algorithm to use for hostname verification.
hostNameVerificationAlgorithm(String) - Method in class io.servicetalk.transport.netty.internal.ClientSecurityConfig: Determines what algorithm to use for hostname verification.
hostnameVerificationAlgorithm - Variable in class io.servicetalk.transport.netty.internal.ReadOnlyClientSecurityConfig
hostnameVerificationAlgorithm() - Method in class io.servicetalk.transport.netty.internal.ReadOnlyClientSecurityConfig: Returns the host name verification algorithm.
hostNameVerificationHost - Variable in class io.servicetalk.transport.netty.internal.ReadOnlyClientSecurityConfig
hostnameVerificationHost() - Method in class io.servicetalk.transport.netty.internal.ReadOnlyClientSecurityConfig: Returns the host name verification host.
hostNameVerificationPort - Variable in class io.servicetalk.transport.netty.internal.ReadOnlyClientSecurityConfig: Only valid if ReadOnlyClientSecurityConfig.hostNameVerificationHost is valid.
hostnameVerificationPort() - Method in class io.servicetalk.transport.netty.internal.ReadOnlyClientSecurityConfig: Returns the host name verification port.
HTTP_1_0 - Static variable in class io.servicetalk.http.api.HttpProtocolVersion: HTTP/1.0 version described in RFC 1945.
HTTP_1_1 - Static variable in class io.servicetalk.http.api.HttpProtocolVersion: HTTP/1.1 version described in RFC 7230.
HTTP_2_0 - Static variable in class io.servicetalk.http.api.HttpProtocolVersion: HTTP/2.0 version described in RFC 7540.
HTTP_VERSION_NOT_SUPPORTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 505 HTTP Version Not Supported
HttpApiConversions - Class in io.servicetalk.http.api: Conversion routines to StreamingHttpService.
HttpApiConversions.ServiceAdapterHolder - Interface in io.servicetalk.http.api: A holder for StreamingHttpService that adapts another service to the streaming programming model.
HttpClient - Interface in io.servicetalk.http.api: Provides a means to issue requests against HTTP service.
HttpClients - Class in io.servicetalk.http.netty: Factory methods for building HttpClient (and other API variations) instances.
HttpConnection - Interface in io.servicetalk.http.api: Represents a single fixed connection to a HTTP server.
HttpConnectionContext - Interface in io.servicetalk.http.api: ConnectionContext for HTTP.
HttpConnectionContext.HttpProtocol - Interface in io.servicetalk.http.api: Provides information about the HTTP protocol.
HttpCookiePair - Interface in io.servicetalk.http.api: Interface defining a HTTP cookie-pair.
HttpDeserializer<T> - Interface in io.servicetalk.http.api: A factory to address deserialization concerns for HTTP request/response payload bodies.
HttpEventKey<T> - Class in io.servicetalk.http.api: A key which identifies a configuration setting for a connection.
HttpExecutionContext - Interface in io.servicetalk.http.api: An extension of ExecutionContext for HTTP.
HttpExecutionStrategies - Class in io.servicetalk.http.api: A factory to create different HttpExecutionStrategy.
HttpExecutionStrategies.Builder - Class in io.servicetalk.http.api: A builder to build an HttpExecutionStrategy.
HttpExecutionStrategy - Interface in io.servicetalk.http.api: An execution strategy for HTTP client and servers.
HttpExecutionStrategyInfluencer - Interface in io.servicetalk.http.api: An entity that wishes to influence HttpExecutionStrategy for an HTTP client or server.
HttpHeaderNames - Class in io.servicetalk.http.api: Common request header names and response header names.
HttpHeaders - Interface in io.servicetalk.http.api: HTTP Header Fields.
HttpHeadersFactory - Interface in io.servicetalk.http.api: Factory method for creating HttpHeaders.
HttpHeaderValues - Class in io.servicetalk.http.api: Common request header values and response header values.
HttpJerseyRouterBuilder - Class in io.servicetalk.http.router.jersey: Builds an StreamingHttpService which routes requests to JAX-RS annotated classes, using Jersey as the routing engine, eg.
HttpJerseyRouterBuilder() - Constructor for class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
HttpMetaData - Interface in io.servicetalk.http.api: Meta data shared between requests and responses.
HttpOutputStream - Class in io.servicetalk.http.api: The OutputStream which provides access to the HTTP trailers.
HttpOutputStream() - Constructor for class io.servicetalk.http.api.HttpOutputStream
HttpPayloadWriter<T> - Interface in io.servicetalk.http.api: An interface which mimics behavior like OutputStream, but allows for writing of objects of type T and provides access to the HTTP trailers.
HttpPredicateRouterBuilder - Class in io.servicetalk.http.router.predicate: Builds an StreamingHttpService which routes requests to a number of other StreamingHttpServices based on user specified criteria.
HttpPredicateRouterBuilder() - Constructor for class io.servicetalk.http.router.predicate.HttpPredicateRouterBuilder
httpProtocol() - Method in interface io.servicetalk.grpc.api.GrpcServiceContext.GrpcProtocol
HttpProtocolConfig - Interface in io.servicetalk.http.api: Defines configuration options for HTTP protocol versions.
HttpProtocolConfigs - Class in io.servicetalk.http.netty: Factory methods for HttpProtocolConfigs and builders for their customization.
HttpProtocolVersion - Class in io.servicetalk.http.api: HTTP protocol versioning.
HttpRequest - Interface in io.servicetalk.http.api: An HTTP request.
HttpRequester - Interface in io.servicetalk.http.api: Provides a means to make a HTTP request.
HttpRequestFactory - Interface in io.servicetalk.http.api: A factory for creating HttpRequests.
HttpRequestMetaData - Interface in io.servicetalk.http.api: Meta data associated with an HTTP request.
HttpRequestMetaDataFactory - Class in io.servicetalk.http.api: A static factory class for HttpRequestMetaData objects.
HttpRequestMethod - Class in io.servicetalk.http.api: HTTP Request Methods.
HttpRequestMethod.Properties - Class in io.servicetalk.http.api: Common HTTP Method Properties.
HttpRequestResponseFactory - Interface in io.servicetalk.http.api: A combination of HttpRequestFactory and HttpResponseFactory.
HttpRequestUriUtils - Class in io.servicetalk.http.utils: Helper methods for computing effective request URIs according to RFC 7230, section 5.5 and base URIs (which are effective request URIs with / as path, and no query nor fragment.
HttpResponse - Interface in io.servicetalk.http.api: An HTTP response.
httpResponseFactory() - Method in interface io.servicetalk.http.api.BlockingHttpRequester: Get a HttpResponseFactory.
httpResponseFactory() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequester: Get a BlockingStreamingHttpResponseFactory.
httpResponseFactory() - Method in interface io.servicetalk.http.api.HttpRequester: Get a HttpResponseFactory.
HttpResponseFactory - Interface in io.servicetalk.http.api: A factory for creating HttpResponses.
httpResponseFactory() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
httpResponseFactory() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
httpResponseFactory() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
httpResponseFactory() - Method in interface io.servicetalk.http.api.StreamingHttpRequester: Get a StreamingHttpResponseFactory.
HttpResponseMetaData - Interface in io.servicetalk.http.api: Meta data associated with an HTTP response.
HttpResponseMetaDataFactory - Class in io.servicetalk.http.api: A static factory class for HttpResponseMetaData objects.
HttpResponseStatus - Class in io.servicetalk.http.api: Response Status Code.
HttpResponseStatus.StatusClass - Enum in io.servicetalk.http.api: The class of response status codes.
HttpSerializationProvider - Interface in io.servicetalk.http.api: A provider of HttpSerializers and HttpDeserializers.
HttpSerializationProviders - Class in io.servicetalk.http.api: A factory to create HttpSerializationProviders.
HttpSerializer<T> - Interface in io.servicetalk.http.api: A factory to address serialization concerns for HTTP request/response payload bodies.
HttpServerBuilder - Class in io.servicetalk.http.api: A builder for building HTTP Servers.
HttpServerBuilder() - Constructor for class io.servicetalk.http.api.HttpServerBuilder
HttpServers - Class in io.servicetalk.http.netty: Factory methods for building HTTP Servers backed by ServerContext.
HttpServerSecurityConfigurator - Interface in io.servicetalk.http.api: A ServerSecurityConfigurator for HttpServerBuilder.
HttpService - Interface in io.servicetalk.http.api: Same as StreamingHttpService but that accepts HttpRequest and returns HttpResponse.
HttpServiceContext - Class in io.servicetalk.http.api: A HttpConnectionContext for use in the HttpService context.
HttpServiceContext(HttpHeadersFactory, HttpResponseFactory, StreamingHttpResponseFactory, BlockingStreamingHttpResponseFactory) - Constructor for class io.servicetalk.http.api.HttpServiceContext: Create a new instance.
HttpServiceContext(HttpServiceContext) - Constructor for class io.servicetalk.http.api.HttpServiceContext: Copy constructor.
HttpSetCookie - Interface in io.servicetalk.http.api: An interface defining a set-cookie-string.
httpVersionNotSupported() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.HTTP_VERSION_NOT_SUPPORTED response.
httpVersionNotSupported() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.HTTP_VERSION_NOT_SUPPORTED response.
httpVersionNotSupported() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.HTTP_VERSION_NOT_SUPPORTED response.

I

IDEMPOTENT - Static variable in class io.servicetalk.http.api.HttpRequestMethod.Properties: As defined in Method Definitions, methods which are idempotent, but not safe or cacheable.
identity() - Static method in interface io.servicetalk.client.api.ConnectionFactoryFilter: Returns a function that always returns its input ConnectionFactory.
identity() - Static method in interface io.servicetalk.client.api.ServiceDiscovererFilterFactory: Returns a function that always returns its input ServiceDiscoverer.
IDENTITY - Static variable in class io.servicetalk.http.api.HttpHeaderValues: "identity"
identity() - Static method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory: Returns a function that always returns its input ConnectionAcceptor.
IDLE_TIMEOUT - Static variable in class io.servicetalk.transport.api.ServiceTalkSocketOptions: Allow to idle timeout in milli seconds after which the connection is closed.
idleTimeout(long, TimeUnit) - Method in class io.servicetalk.concurrent.api.Completable: Creates a new Completable that will mimic the signals of this Completable but will terminate with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(long, TimeUnit, Executor) - Method in class io.servicetalk.concurrent.api.Completable: Creates a new Completable that will mimic the signals of this Completable but will terminate with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(Duration) - Method in class io.servicetalk.concurrent.api.Completable: Creates a new Completable that will mimic the signals of this Completable but will terminate with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(Duration, Executor) - Method in class io.servicetalk.concurrent.api.Completable: Creates a new Completable that will mimic the signals of this Completable but will terminate with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(long, TimeUnit) - Method in class io.servicetalk.concurrent.api.Publisher: Creates a new Publisher that will mimic the signals of this Publisher but will terminate with a TimeoutException if time duration elapses between adjacent PublisherSource.Subscriber.onNext(Object) calls.
idleTimeout(Duration) - Method in class io.servicetalk.concurrent.api.Publisher: Creates a new Publisher that will mimic the signals of this Publisher but will terminate with a TimeoutException if time duration elapses between adjacent PublisherSource.Subscriber.onNext(Object) calls.
idleTimeout(long, TimeUnit, Executor) - Method in class io.servicetalk.concurrent.api.Publisher: Creates a new Publisher that will mimic the signals of this Publisher but will terminate with a TimeoutException if time duration elapses between adjacent PublisherSource.Subscriber.onNext(Object) calls.
idleTimeout(Duration, Executor) - Method in class io.servicetalk.concurrent.api.Publisher: Creates a new Publisher that will mimic the signals of this Publisher but will terminate with a TimeoutException if time duration elapses between adjacent PublisherSource.Subscriber.onNext(Object) calls.
idleTimeout(long, TimeUnit) - Method in class io.servicetalk.concurrent.api.Single: Creates a new Single that will mimic the signals of this Single but will terminate with a with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(long, TimeUnit, Executor) - Method in class io.servicetalk.concurrent.api.Single: Creates a new Single that will mimic the signals of this Single but will terminate with a with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(Duration) - Method in class io.servicetalk.concurrent.api.Single: Creates a new Single that will mimic the signals of this Single but will terminate with a with a TimeoutException if time duration elapses between subscribe and termination.
idleTimeout(Duration, Executor) - Method in class io.servicetalk.concurrent.api.Single: Creates a new Single that will mimic the signals of this Single but will terminate with a with a TimeoutException if time duration elapses between subscribe and termination.
IdleTimeoutInitializer - Class in io.servicetalk.transport.netty.internal: Initializes the channel with idle timeout handling.
IdleTimeoutInitializer(Duration) - Constructor for class io.servicetalk.transport.netty.internal.IdleTimeoutInitializer: New instance.
IdleTimeoutInitializer(long) - Constructor for class io.servicetalk.transport.netty.internal.IdleTimeoutInitializer: New instance.
IF_MATCH - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "if-match"
IF_MODIFIED_SINCE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "if-modified-since"
IF_NONE_MATCH - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "if-none-match"
IF_RANGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "if-range"
IF_UNMODIFIED_SINCE - Static variable in class io.servicetalk.http.api.HttpHeaderNames: "if-unmodified-since"
IGNORE_CANCEL - Static variable in interface io.servicetalk.concurrent.Cancellable: A no-op instance of Cancellable.
ignoreActiveSpan() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
IgnoreConsumedEvent<T> - Class in io.servicetalk.client.api.internal: A ConsumableEvent which ignores IgnoreConsumedEvent.eventConsumed().
IgnoreConsumedEvent(T) - Constructor for class io.servicetalk.client.api.internal.IgnoreConsumedEvent: Create a new instance.
ignoreElement() - Method in class io.servicetalk.concurrent.api.Single: Ignores the result of this Single and forwards the termination signal to the returned Completable.
ignoreElements() - Method in class io.servicetalk.concurrent.api.Publisher: Ignores all elements emitted by this Publisher and forwards the termination signal to the returned Completable.
IM_USED - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 226 IM Used
immediate() - Static method in class io.servicetalk.concurrent.api.Executors: Returns an Executor that executes all tasks submitted via Executor.execute(Runnable) immediately by calling Runnable.run() on the calling thread.
imUsed() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.IM_USED response.
imUsed() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.IM_USED response.
imUsed() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.IM_USED response.
indexOf(int, int, byte) - Method in interface io.servicetalk.buffer.api.Buffer: Locates the first occurrence of the specified value in this buffer.
indexOf(int, int, byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
indexOf(X, X[]) - Static method in class io.servicetalk.concurrent.internal.ArrayUtils: Find the index of l in array.
indexOf(CharSequence, char, int) - Static method in class io.servicetalk.http.api.CharSequences: Find the index of c within sequence starting at index fromIndex.
influenceStrategy(HttpExecutionStrategy) - Method in interface io.servicetalk.http.api.HttpExecutionStrategyInfluencer: Optionally modify the passed HttpExecutionStrategy to a new HttpExecutionStrategy that suits this HttpExecutionStrategyInfluencer.
influenceStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter
influenceStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
influenceStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.utils.RetryingHttpRequesterFilter
influenceStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
influenceStrategy(HttpExecutionStrategy) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
init(Channel) - Method in class io.servicetalk.tcp.netty.internal.TcpClientChannelInitializer
init(Channel) - Method in class io.servicetalk.tcp.netty.internal.TcpServerChannelInitializer
init(Channel) - Method in interface io.servicetalk.transport.netty.internal.ChannelInitializer: Configures the passed Channel.
init(Channel) - Method in class io.servicetalk.transport.netty.internal.CopyByteBufHandlerChannelInitializer
init(Channel) - Method in class io.servicetalk.transport.netty.internal.IdleTimeoutInitializer
init(Channel) - Method in class io.servicetalk.transport.netty.internal.SslClientChannelInitializer
init(Channel) - Method in class io.servicetalk.transport.netty.internal.SslServerChannelInitializer
init(Channel) - Method in class io.servicetalk.transport.netty.internal.WireLoggingInitializer
initChannel(Channel, BufferAllocator, Executor, NettyConnection.TerminalPredicate<Read>, CloseHandler, FlushStrategy, Long, ChannelInitializer, ExecutionStrategy, ConnectionContext.Protocol) - Static method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection: Given a Channel this will initialize the ChannelPipeline and create a DefaultNettyConnection.
initChildChannel(Channel, BufferAllocator, Executor, NettyConnection.TerminalPredicate<Read>, CloseHandler, FlushStrategy, Long, ExecutionStrategy, ConnectionContext.Protocol, SSLSession, ChannelConfig) - Static method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection: Given a Channel this will initialize the ChannelPipeline just to create a DefaultNettyConnection.
initNext(CharSequence) - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator: Initialize the next HttpCookiePair value for HeaderUtils.CookiesByNameIterator.next().
initNext(CharSequence) - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator: Initialize the next HttpCookiePair value for HeaderUtils.CookiesIterator.next().
initRequestProperties(BufferPublisherInputStream, ContainerRequestContext) - Static method in class io.servicetalk.http.router.jersey.internal.RequestProperties: Initialize all request properties.
inject(SpanContext, Format<C>, C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
inject(InMemorySpanContext, Format<C>, C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer: Same as InMemoryTracer.inject(SpanContext, Format, Object) but requires a InMemorySpanContext.
inject(InMemoryTraceState, C) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTraceStateFormat: Inject a trace state into a carrier.
inject(InMemoryTraceState, SingleLineValue) - Method in class io.servicetalk.opentracing.inmemory.SingleLineFormatter
injectSpanContextIntoResponse(SpanContext) - Method in class io.servicetalk.opentracing.http.TracingHttpServiceFilter: Determine if the current span context should be injected into the response.
InMemoryReference - Interface in io.servicetalk.opentracing.inmemory.api: Represents a reference to another span.
InMemoryScope - Interface in io.servicetalk.opentracing.inmemory.api: A Scope that works with InMemorySpan instances.
InMemoryScopeManager - Interface in io.servicetalk.opentracing.inmemory.api: A ScopeManager that works with InMemoryScope instances.
InMemorySpan - Interface in io.servicetalk.opentracing.inmemory.api: A span that allows reading values at runtime.
InMemorySpanBuilder - Interface in io.servicetalk.opentracing.inmemory.api: A Tracer.SpanBuilder that works with InMemorySpan instances.
InMemorySpanContext - Interface in io.servicetalk.opentracing.inmemory.api: A span that allows reading values at runtime.
InMemorySpanEventListener - Interface in io.servicetalk.opentracing.inmemory.api: Listener for tracing events.
InMemorySpanLog - Interface in io.servicetalk.opentracing.inmemory.api: A entry that corresponds to Span.log(long, String) events.
InMemoryTracer - Interface in io.servicetalk.opentracing.inmemory.api: A Tracer that works with InMemorySpan instances.
InMemoryTraceState - Interface in io.servicetalk.opentracing.inmemory.api: Utility for representing a Ziplin-like trace state.
InMemoryTraceStateFormat<C> - Interface in io.servicetalk.opentracing.inmemory.api: A Format compatible with InMemoryTraceState.
INSTANCE - Static variable in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMapFactory
INSTANCE - Static variable in class io.servicetalk.http.api.DefaultHttpHeadersFactory
INSTANCE - Static variable in class io.servicetalk.http.api.EmptyHttpHeaders
INSTANCE - Static variable in class io.servicetalk.http.netty.H2HeadersFactory
INSTANCE - Static variable in class io.servicetalk.opentracing.inmemory.SingleLineFormatter
INSTANCE - Static variable in class io.servicetalk.transport.netty.internal.BufferHandler
INSUFFICIENT_STORAGE - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 507 Insufficient Storage
insufficientStorage() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.INSUFFICIENT_STORAGE response.
insufficientStorage() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.INSUFFICIENT_STORAGE response.
insufficientStorage() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.INSUFFICIENT_STORAGE response.
INTERNAL_SERVER_ERROR - Static variable in class io.servicetalk.http.api.HttpResponseStatus: 500 Internal Server Error
internalServerError() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory: Create a new HttpResponseStatus.INTERNAL_SERVER_ERROR response.
internalServerError() - Method in interface io.servicetalk.http.api.HttpResponseFactory: Create a new HttpResponseStatus.INTERNAL_SERVER_ERROR response.
internalServerError() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory: Create a new HttpResponseStatus.INTERNAL_SERVER_ERROR response.
invalidateHostsOnDnsFailure(Predicate<Throwable>) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Allows sending 'unavailable' events for all current active hosts for particular DNS errors.
InvalidRedirectException - Exception in io.servicetalk.http.utils: Throws when redirect could not be performed.
invokeClient(Publisher<Object>, State) - Method in interface io.servicetalk.http.api.ClientInvoker: Invokes the client.
invokeClient(Executor, Publisher<Object>, FS, ClientInvoker<FS>) - Method in interface io.servicetalk.http.api.HttpExecutionStrategy: Invokes the passed Function and applies the necessary offloading of request and response for a client.
invokeService(Executor, StreamingHttpRequest, Function<StreamingHttpRequest, Publisher<Object>>, BiFunction<Throwable, Executor, Publisher<Object>>) - Method in interface io.servicetalk.http.api.HttpExecutionStrategy: Invokes the passed Function and applies the necessary offloading of request and response for a server.
invokeService(Executor, Function<Executor, T>) - Method in interface io.servicetalk.http.api.HttpExecutionStrategy: Invokes a service represented by the passed Function.
io.servicetalk.annotations - package io.servicetalk.annotations
io.servicetalk.buffer.api - package io.servicetalk.buffer.api
io.servicetalk.buffer.netty - package io.servicetalk.buffer.netty: Package that contains internal implementations for buffers.
io.servicetalk.client.api - package io.servicetalk.client.api
io.servicetalk.client.api.internal - package io.servicetalk.client.api.internal
io.servicetalk.client.api.internal.partition - package io.servicetalk.client.api.internal.partition
io.servicetalk.client.api.partition - package io.servicetalk.client.api.partition
io.servicetalk.concurrent - package io.servicetalk.concurrent
io.servicetalk.concurrent.api - package io.servicetalk.concurrent.api
io.servicetalk.concurrent.api.internal - package io.servicetalk.concurrent.api.internal
io.servicetalk.concurrent.internal - package io.servicetalk.concurrent.internal
io.servicetalk.concurrent.reactivestreams - package io.servicetalk.concurrent.reactivestreams
io.servicetalk.data.jackson - package io.servicetalk.data.jackson
io.servicetalk.data.jackson.jersey - package io.servicetalk.data.jackson.jersey
io.servicetalk.data.jackson.jersey.config - package io.servicetalk.data.jackson.jersey.config
io.servicetalk.data.protobuf - package io.servicetalk.data.protobuf
io.servicetalk.dns.discovery.netty - package io.servicetalk.dns.discovery.netty
io.servicetalk.grpc.api - package io.servicetalk.grpc.api
io.servicetalk.grpc.netty - package io.servicetalk.grpc.netty
io.servicetalk.grpc.protobuf - package io.servicetalk.grpc.protobuf
io.servicetalk.grpc.protoc - package io.servicetalk.grpc.protoc
io.servicetalk.http.api - package io.servicetalk.http.api: The HTTP API package.
io.servicetalk.http.netty - package io.servicetalk.http.netty: The HTTP netty package.
io.servicetalk.http.router.jersey - package io.servicetalk.http.router.jersey
io.servicetalk.http.router.jersey.config - package io.servicetalk.http.router.jersey.config
io.servicetalk.http.router.jersey.internal - package io.servicetalk.http.router.jersey.internal
io.servicetalk.http.router.predicate - package io.servicetalk.http.router.predicate: HTTP routing based upon predicates.
io.servicetalk.http.router.predicate.dsl - package io.servicetalk.http.router.predicate.dsl: DSL for building HTTP routers based upon predicates.
io.servicetalk.http.security.auth.basic.jersey - package io.servicetalk.http.security.auth.basic.jersey
io.servicetalk.http.utils - package io.servicetalk.http.utils: HTTP utilities based upon the HTTP API package.
io.servicetalk.http.utils.auth - package io.servicetalk.http.utils.auth
io.servicetalk.loadbalancer - package io.servicetalk.loadbalancer
io.servicetalk.log4j2.mdc.utils - package io.servicetalk.log4j2.mdc.utils
io.servicetalk.oio.api - package io.servicetalk.oio.api: The OIO API package.
io.servicetalk.opentracing.asynccontext - package io.servicetalk.opentracing.asynccontext
io.servicetalk.opentracing.http - package io.servicetalk.opentracing.http
io.servicetalk.opentracing.inmemory - package io.servicetalk.opentracing.inmemory
io.servicetalk.opentracing.inmemory.api - package io.servicetalk.opentracing.inmemory.api
io.servicetalk.opentracing.internal - package io.servicetalk.opentracing.internal
io.servicetalk.opentracing.log4j2 - package io.servicetalk.opentracing.log4j2
io.servicetalk.opentracing.zipkin.publisher - package io.servicetalk.opentracing.zipkin.publisher
io.servicetalk.router.api - package io.servicetalk.router.api
io.servicetalk.router.utils.internal - package io.servicetalk.router.utils.internal
io.servicetalk.serialization.api - package io.servicetalk.serialization.api
io.servicetalk.tcp.netty.internal - package io.servicetalk.tcp.netty.internal: The TCP Internal package.
io.servicetalk.test.resources - package io.servicetalk.test.resources: The test resources package.
io.servicetalk.transport.api - package io.servicetalk.transport.api
io.servicetalk.transport.netty - package io.servicetalk.transport.netty
io.servicetalk.transport.netty.internal - package io.servicetalk.transport.netty.internal
io.servicetalk.utils.internal - package io.servicetalk.utils.internal
ioExecutor(IoExecutor) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder: Sets the IoExecutor.
ioExecutor(IoExecutor) - Method in class io.servicetalk.grpc.api.GrpcClientBuilder
ioExecutor(IoExecutor) - Method in class io.servicetalk.grpc.api.GrpcServerBuilder: Sets the IoExecutor to be used by this server.
ioExecutor() - Method in class io.servicetalk.http.api.DefaultHttpExecutionContext
ioExecutor() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
ioExecutor(IoExecutor) - Method in class io.servicetalk.http.api.HttpServerBuilder: Sets the IoExecutor to be used by this server.
ioExecutor(IoExecutor) - Method in class io.servicetalk.http.api.MultiAddressHttpClientBuilder
ioExecutor(IoExecutor) - Method in class io.servicetalk.http.api.PartitionedHttpClientBuilder
ioExecutor(IoExecutor) - Method in class io.servicetalk.http.api.SingleAddressHttpClientBuilder
ioExecutor() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
ioExecutor() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
ioExecutor() - Method in interface io.servicetalk.transport.api.ExecutionContext: Get the IoExecutor that is used to handle the IO.
IoExecutor - Interface in io.servicetalk.transport.api: Executor that handles IO.
ioExecutor(IoExecutor) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder: Sets the IoExecutor to use.
IoThreadFactory - Class in io.servicetalk.transport.netty.internal: Default ThreadFactory to create IO Threads.
IoThreadFactory(String) - Constructor for class io.servicetalk.transport.netty.internal.IoThreadFactory: Create a new instance.
IoThreadFactory(String, boolean) - Constructor for class io.servicetalk.transport.netty.internal.IoThreadFactory: Create a new instance.
isAvailable() - Method in class io.servicetalk.client.api.DefaultServiceDiscovererEvent
isAvailable() - Method in interface io.servicetalk.client.api.ServiceDiscovererEvent: Determine if ServiceDiscovererEvent.address() is now available or unavailable.
isCacheable() - Method in class io.servicetalk.http.api.HttpRequestMethod.Properties: Cacheable Methods are those that allow for responses to be cached for future reuse.
isCancelled() - Method in class io.servicetalk.concurrent.internal.SequentialCancellable: Returns true if this Cancellable is cancelled.
isClosed() - Method in class io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream
isClosed() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream: Determine if AbstractCloseableIteratorAsInputStream.close() has been called.
isConnectAllowed(ResolvedAddress) - Method in interface io.servicetalk.client.api.LimitingConnectionFactoryFilter.ConnectionLimiter: Requests permission to create a single connection to the passed target address.
isCurrentThreadEventLoop() - Method in interface io.servicetalk.transport.netty.internal.EventLoopAwareNettyIoExecutor: Checks if the calling thread is an I/O thread manager by this NettyIoExecutor.
isDataReceiveOffloaded() - Method in interface io.servicetalk.http.api.HttpExecutionStrategy: Returns true if data receive offloading is enabled for this ExecutionStrategy.
isDirect() - Method in interface io.servicetalk.buffer.api.Buffer: Returns true if the buffer is direct and so not allocated on the heap.
isDirect() - Method in class io.servicetalk.buffer.api.EmptyBuffer
isEmpty() - Method in interface io.servicetalk.client.api.partition.PartitionAttributes: Determine if there are no key/value pairs in this collection.
isEmpty() - Static method in class io.servicetalk.concurrent.api.AsyncContext: Convenience method to determine if there are no key/value pairs in the current context.
isEmpty() - Method in interface io.servicetalk.concurrent.api.AsyncContextMap: Determine if there are no key/value pairs in this AsyncContextMap.
isEmpty() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
isEmpty() - Method in interface io.servicetalk.http.api.HttpHeaders: Returns true if HttpHeaders.size() equals 0.
isEmpty() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
isEmpty() - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
isFileDescriptorSocketAddressSup