All Classes

Class	Description
AbstractCloseableIterable<T>	An abstract implementation of CloseableIterable that wraps an Iterable.
AbstractCloseableIteratorAsInputStream<T>	Conversion from a CloseableIterator to a InputStream given a Function to serialize to bytes.
AbstractFilterInterceptorTest
AbstractFilterInterceptorTest.TestGlobalFilter
AbstractFilterInterceptorTest.TestGlobalInterceptor
AbstractFilterInterceptorTest.TestInputConsumingGlobalFilter
AbstractFilterInterceptorTest.UpperCaseInputStream
AbstractHttpRequesterFilterTest	This parameterized test facilitates running HTTP requester filter tests under all calling variations: client, connection, reserved connection, with and without SSL context.
AbstractHttpRequesterFilterTest.RequesterType
AbstractHttpRequesterFilterTest.RequestHandler	Handler for HttpRequester.request(HttpExecutionStrategy, HttpRequest) calls as delegated from the filter under test.
AbstractHttpRequesterFilterTest.RequestWithContextHandler	Handler for HttpRequester.request(HttpExecutionStrategy, HttpRequest) calls with ConnectionContext information as delegated from the filter under test.
AbstractHttpRequesterFilterTest.SecurityType
AbstractHttpServiceFilterTest	This parameterized test facilitates running HTTP service filter tests under all calling variations: with and without SSL context.
AbstractHttpServiceFilterTest.SecurityType
AbstractJerseyStreamingHttpServiceTest
AbstractNonParameterizedJerseyStreamingHttpServiceTest
AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi
AbstractResourceTest
AbstractResourceTest.TestApplication
AbstractResourceTest.TestFilter
AbstractResourceTest.TestFiltered
AbstractRetryingFilterBuilder<Builder extends AbstractRetryingFilterBuilder<Builder,Filter,Meta>,Filter,Meta>	An abstract builder for retrying filters.
AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<Meta>	A read-only settings for retryable filters.
AddressUtils	A utility class to work with addresses.
ArrayUtils	Utilities for arrays.
AsyncCloseable	Used to close/shutdown a resource.
AsyncCloseables	A utility class to create AsyncCloseables.
AsyncCloseables.CloseableResource	A resource that can be converted to an AsyncCloseable.
AsyncContext	Presents a static interface to retain state in an asynchronous environment.
AsyncContextInMemoryScopeManager	A InMemoryScopeManager that uses AsyncContext as the backing storage.
AsyncContextMap	The key-value map stored in the AsyncContext.
AsyncContextMap.Key<T>	A key identifies a specific object in a AsyncContextMap.
AsyncContextMapHolder	Interface for setting and getting a AsyncContextMap.
AsynchronousResources	Asynchronous (in JAX-RS lingo) resources.
AsynchronousResourceTest
AuthenticationException	An authentication exception, which indicates that access was denied and usually converts to 401 (Unauthorized) or 407 (Proxy Authentication Required) response.
AutoClosableUtils	Utilities for AutoCloseable.
AutoCloseables	A utility class for methods related to AutoCloseable.
AutoOnSubscribeCompletableSubscriberFunction	Calls CompletableSource.Subscriber.onSubscribe(Cancellable) automatically, sending a delegating Cancellable.
AutoOnSubscribePublisherSubscriberFunction<T>	Calls PublisherSource.Subscriber.onSubscribe(Subscription) automatically, sending a delegating PublisherSource.Subscription.
AutoOnSubscribeSingleSubscriberFunction<T>	Calls SingleSource.Subscriber.onSubscribe(Cancellable) automatically, sending a delegating Cancellable.
AutoRetryStrategyProvider	A provider for AutoRetryStrategyProvider.AutoRetryStrategy.
AutoRetryStrategyProvider.AutoRetryStrategy	A strategy to use for automatic retries.
BaseJerseyRouterTestSuite
BasicAuthenticated	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>	A StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
BasicAuthHttpServiceFilter.Builder<UserInfo>	A builder for an StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
BasicAuthHttpServiceFilter.CredentialsVerifier<UserInfo>	Verifies user-id and password, parsed from the 'Basic' HTTP Authentication Scheme credentials.
BasicAuthPrincipal<UserInfo>	A generic Principal that wraps a user provided UserInfo.
BasicAuthSecurityContext	A generic SecurityContext that wraps a user provided Principal, and which is designed for the SecurityContext.BASIC_AUTH authentication scheme.
BasicAuthSecurityContextFilters	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>	A builder for ContainerRequestFilter instances.
BasicAuthSecurityContextFilters.NoUserInfoBuilder	A builder that can be used when no user info is stored in AsyncContext.
BasicAuthSecurityContextFilters.UserInfoBuilder<UserInfo>	A builder that can be used when user info is stored in AsyncContext.
BeforeFinallyHttpOperator	Helper operator for signaling the end of an HTTP Request/Response cycle.
BiIntFunction<T,R>	A special function that takes an int and a custom argument and returns the result.
BiIntPredicate<T>	A special predicate that takes an int and a custom argument to evaluate.
BlockingGrpcClient<Client extends GrpcClient>	A blocking client to a gRPC service.
BlockingGrpcService	A blocking gRPC service.
BlockingHttpClient	The equivalent of HttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpConnection	The equivalent of HttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpRequester	The equivalent of HttpRequester with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpService	The equivalent of HttpService but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingIterable<T>	An Iterable which supports generation of BlockingIterators.
BlockingIterable.Processor<T>	A BlockingIterable that supports to dynamically emitting items using BlockingIterable.Processor.next(Object).
BlockingIterables	Utility methods for BlockingIterable.
BlockingIterator<T>	An Iterator that is also an AutoCloseable and whose blocking operations support timeout durations.
BlockingProcessorSignalsHolder<T>	A holder of items for a BlockingIterable.Processor.
BlockingSpliterator<T>	An Spliterator which supports AutoCloseable.close().
BlockingStreamingHttpClient	The equivalent of StreamingHttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpConnection	The equivalent of StreamingHttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpRequest	The equivalent of HttpRequest but provides the payload as a BlockingIterable.
BlockingStreamingHttpRequester	The equivalent of StreamingHttpRequester but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpRequestFactory	A factory for creating BlockingStreamingHttpRequests.
BlockingStreamingHttpRequestResponseFactory	A combination of BlockingStreamingHttpRequestFactory and BlockingStreamingHttpResponseFactory.
BlockingStreamingHttpResponse	The equivalent of HttpResponse but provides the payload as a BlockingIterable.
BlockingStreamingHttpResponseFactory	A factory for creating BlockingStreamingHttpResponses.
BlockingStreamingHttpServerResponse	The equivalent of HttpResponse but provides an ability to write the payload to an HttpPayloadWriter.
BlockingStreamingHttpService	The equivalent of StreamingHttpService but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingTestUtils	Utilities to await results of an asynchronous computation either by blocking the calling thread.
Buffer	An arbitrary and sequential accessible sequence of zero or more bytes (octets).
BufferAllocator	An API to allocate Buffers.
BufferAllocators	Available BufferAllocators.
BufferHandler	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	An object which contains a Buffer.
BufferPublisherInputStream	An InputStream built around a Publisher<Buffer>, which can either be read OIO style or provide its wrapped Publisher.
BufferStrategies	A static factory of BufferStrategy instances.
BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B>	A strategy for buffering items emitted from a Publisher.
BufferStrategy.Accumulator<T,B>	An intermediate mutable object that holds items till it is finished.
BufferUtils	Internal utilities for Buffers.
BuilderUtils	Utilities which are used for builders.
ByteProcessor	Provides a mechanism to iterate over a collection of bytes.
ByteToMessageDecoder	ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an other Message type.
CancelImmediatelySubscriber	A PublisherSource.Subscriber that invokes Cancellable.cancel() in PublisherSource.Subscriber.onSubscribe(Subscription).
Cancellable	An entity that can be cancelled.
CancellableResources
CancellationTest
ChannelCloseUtils	Utilities to handle Channel closure and its reason.
ChannelInitializer	Configures a Channel.
ChannelSet	Manages a set of Channels to provide a mechanism for closing all of them.
CharSequences	8-bit ASCII strings factory and basic utilities helper.
CharSequences	Deprecated. This class is deprecated and will be removed in a future release.
ClientGroup<Key,Client extends ListenableAsyncCloseable>	A data-structure capable of holding arbitrary number of clients and bridging lifecycle events across all clients managed by the group.
ClientInvoker<State>	A function that given flattened stream of HttpRequestMetaData, payload and trailers, for the passed StreamingHttpRequest returns a Single.
ClientSecurityConfig	Deprecated. Use ClientSslConfig.
ClientSecurityConfigurator	Deprecated. Use ClientSslConfigBuilder.
ClientSslConfig	Specifies the configuration for client side TLS/SSL.
ClientSslConfigBuilder	Default builder for ClientSslConfig objects.
CloseableIterable<T>	An Iterable which supports generation of CloseableIterators.
CloseableIterator<T>	An Iterator that is also an AutoCloseable.
CloseableIteratorBufferAsInputStream	Conversion from a CloseableIterator of Buffers to a InputStream.
ClosedPartitionException	Thrown when a request is issued against a valid partition that was closed after selection.
CloseHandler	Contract between protocol codecs and a close handler.
CloseHandler.CloseEvent	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	ClosedChannelException with additional meta-data to provide more context on what side initiated the close event.
CloseHandler.DiscardFurtherInboundEvent	Netty UserEvent to indicate the further inbound data should be discarded.
Codec	Zipkin data formats for reporting of Spans.
CodecDecodingException	Exception thrown when something goes wrong during decoding.
CodecEncodingException	Exception thrown when something goes wrong during encoding.
Completable	An asynchronous computation that does not emit any data.
CompletableFirstStep	Provides the ability to express expectations for the first step in a Subscriber's lifecycle.
CompletableLastStep	Provides the ability to express expectations for the terminal signals (e.g.
CompletableOperator	An operator contract for a Completable.
CompletableSource	An asynchronous computation that does not emit any data.
CompletableSource.Processor	A CompletableSource.Processor represents a processing stage that is both a CompletableSource and a CompletableSource.Subscriber and obeys the contracts of both.
CompletableSource.Subscriber	Subscriber of the outcome of a Cancellable.
CompositeBuffer	A virtual Buffer which shows multiple buffers as a single merged buffer.
CompositeCloseable	A AsyncCloseable and Closeable that allows for adding new AsyncCloseables till it is closed.
ConcurrentCompletableSubscriberFunction	Allows multiple CompletableSource.Subscribers to be concurrently subscribed to a TestCompletable, and multicasts signals to them all.
ConcurrentPublisherSubscriberFunction<T>	Allows multiple PublisherSource.Subscribers to be concurrently subscribed to a TestPublisher, and multicasts signals to them all.
ConcurrentSingleSubscriberFunction<T>	Allows multiple SingleSource.Subscribers to be concurrently subscribed to a TestSingle, and multicasts signals to them all.
ConcurrentSubscription	This class prevents concurrent invocation of PublisherSource.Subscription methods and preserves the Reactive Streams, 2.7 rule when there is a possibility of concurrency.
ConcurrentTerminalSubscriber<T>	A PublisherSource.Subscriber that allows for concurrent delivery of terminal events.
ConcurrentUtils	Utilities which can be used for concurrency.
ConditionalFilterFactory
ConditionalFilterFactory.FilterFactory
ConnectableBufferOutputStream	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.
ConnectablePayloadWriter<T>	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.
ConnectionAcceptor	A contract that defines the connection acceptance criterion.
ConnectionAcceptorFactory	A factory of DelegatingConnectionAcceptor.
ConnectionClosedException	Thrown when the connection is no longer available.
ConnectionContext	A context for a connection.
ConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable>	A factory for creating new connections.
ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A contract to decorate ConnectionFactory instances for the purpose of filtering.
ConnectionInfo	Provides information about a connection.
ConnectionInfo.Protocol	Provides information about the network protocol.
ConnectionObserver	An observer interface that provides visibility into events associated with a network connection.
ConnectionObserver.DataObserver	An observer interface that provides visibility into read and write events related to data flow.
ConnectionObserver.MultiplexedObserver	An observer interface that provides visibility into new streams created by a multiplexed connection.
ConnectionObserver.ReadObserver	An observer interface that provides visibility into read events.
ConnectionObserver.SecurityHandshakeObserver	An observer interface that provides visibility into security handshake events.
ConnectionObserver.StreamObserver	An observer interface that provides visibility into stream events.
ConnectionObserver.WriteObserver	An observer interface that provides visibility into write events.
ConnectionObserverInitializer	A ChannelInitializer that registers a ConnectionObserver for all channels.
ConnectionRejectedException	Thrown when a newly created connection was rejected.
ConnectTimeoutException	Throws when a connect operations failed because of a timeout.
ConsumableEvent<T>	A container for an event that requires acknowledgement when the event is consumed via ConsumableEvent.eventConsumed().
ContentCodec	API to support encode and decode of Buffers.
ContentCodecBuilder	Deprecated. encoding-api based solution is being replaced with a netty implementation available under servicetalk-encoding-netty dependency.
ContentCodingHttpRequesterFilter	A StreamingHttpClientFilter that adds encoding / decoding functionality for requests and responses respectively, as these are specified by the spec Content-Encoding.
ContentCodingHttpServiceFilter	A StreamingHttpService that adds encoding / decoding functionality for responses and requests respectively, as these are specified by the spec Content-Encoding.
ContentCodings	Deprecated. API replaced by io.servicetalk.encoding.netty.ContentCodings
ContentCodings	Common available encoding implementations.
ContextFilterSuccessful	Netty pipeline event that represents the successful completion of the ConnectionAcceptor.
CookieMatcher	Methods for route matching on cookies.
CopyByteBufHandlerChannelInitializer	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).
DefaultAutoRetryStrategyProvider	Default implementation for AutoRetryStrategyProvider.
DefaultAutoRetryStrategyProvider.Builder	A builder for DefaultAutoRetryStrategyProvider.
DefaultDnsServiceDiscovererBuilder	Builder for DNS ServiceDiscoverer which will attempt to resolve A, AAAA, CNAME, and SRV type queries.
DefaultExecutionContext	A default implementation of ExecutionContext.
DefaultGroupKey<Address>	A default implementation of GroupKey.
DefaultGrpcClientMetadata	Default implementation for DefaultGrpcClientMetadata.
DefaultHttpCookiePair	Default implementation of HttpCookiePair.
DefaultHttpExecutionContext	Default implementation of HttpExecutionContext.
DefaultHttpHeadersFactory	Default implementation of HttpHeadersFactory.
DefaultHttpLoadBalancerFactory<ResolvedAddress>	Default implementation of HttpLoadBalancerFactory.
DefaultHttpLoadBalancerFactory.Builder<ResolvedAddress>	A builder for creating instances of DefaultHttpLoadBalancerFactory.
DefaultHttpSetCookie	Default implementation of HttpSetCookie.
DefaultInMemoryTracer	Tracer implementation that propagates spans in-memory and emits events to listeners.
DefaultInMemoryTracer.Builder	Builders for DefaultInMemoryTracer.
DefaultInMemoryTraceState	Default implementation of InMemoryTraceState.
DefaultNettyConnection<Read,Write>	Implementation of NettyConnection backed by a netty Channel.
DefaultPartitionAttributesBuilder	Default implementation of PartitionAttributesBuilder.
DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable>	An implementation of ClientGroup that can be used for partitioned client use-cases where PartitionAttributes are discovered through PartitionedServiceDiscovererEvents.
DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client>	Factory for building partitioned clients.
DefaultRouteExecutionStrategyFactory<ES extends ExecutionStrategy>	Implementation of RouteExecutionStrategyFactory that always throws IllegalArgumentException.
DefaultSerializer	Default implementation for Serializer.
DefaultServiceDiscovererEvent<T>	Default implementation of ServiceDiscovererEvent.
DefaultServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>	Default implementation for ServiceDiscoveryRetryStrategy.
DefaultServiceDiscoveryRetryStrategy.Builder<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>	A builder to build instances of DefaultServiceDiscoveryRetryStrategy.
DefaultServiceTalkThreadContextMap	Empty subclass to differentiate uses of MDC.
DefaultStreamingHttpRequestResponseFactory	A default implementation for StreamingHttpRequestFactory and StreamingHttpResponseFactory.
DefaultTestCerts	Provides a set of certificates useful for tests that require SSL.
DefaultThreadFactory	A ThreadFactory implementation.
DefaultUserDataLoggerConfig	Default implementation of LoggerConfig.
DeferredEmptySubscription	An PublisherSource.Subscription that only emits a TerminalNotification only upon the first call to DeferredEmptySubscription.request(long).
DeferSslHandler	A ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler.
DelayedCancellable	A Cancellable which serves as a placeholder until the "real" Cancellable is available.
DelayedSubscription	A PublisherSource.Subscription which serves as a placeholder until the "real" PublisherSource.Subscription is available.
DelegatingConnectionAcceptor	An implementation of ConnectionAcceptor that delegates all methods to another ConnectionAcceptor.
DelegatingConnectionContext	A ConnectionContext implementation that delegates all calls to a provided ConnectionContext.
DelegatingConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactory that delegates all methods to another ConnectionFactory.
DelegatingExecutionContext	An ExecutionContext implementation that delegates all calls to a provided ExecutionContext.
DelegatingExecutor	An Executor that simply delegates all calls to another Executor.
DelegatingFlushStrategy	A FlushStrategy implementation that delegates all calls to another FlushStrategy.
DelegatingHttpConnectionContext	HttpConnectionContext implementation that delegates all calls to a provided HttpConnectionContext.
DelegatingHttpExecutionContext	An implementation of HttpExecutionContext that delegates all method calls to another HttpExecutionContext.
DelegatingHttpExecutionStrategy	An HttpExecutionStrategy that delegates all method calls to another HttpExecutionStrategy.
DelegatingHttpServiceContext	An implementation of HttpServiceContext that delegates all calls to a provided HttpServiceContext.
DelegatingSignalOffloader	A SignalOffloader that delegates all calls to another SignalOffloader.
DelegatingSignalOffloaderFactory	A SignalOffloaderFactory that delegates all calls to another SignalOffloaderFactory.
DeliberateException
DemandCheckingSubscriber<T>	A PublisherSource.Subscriber that wraps another, and asserts that items are not delivered without sufficient demand.
DemandCheckingSubscriberFunction<T>	Wraps PublisherSource.Subscribers in a DemandCheckingSubscriber.
DnsResolverAddressTypes	Defined resolved address types.
DnsServerAddressStream	An infinite stream of DNS server addresses.
DnsServerAddressStreamProvider	Provides an opportunity to override which DnsServerAddressStream is used to resolve a specific hostname.
DnsServiceDiscovererObserver	An observer that provides visibility into DNS ServiceDiscoverer built by DefaultDnsServiceDiscovererBuilder.
DnsServiceDiscovererObserver.DnsDiscoveryObserver	An observer that provides visibility into individual DNS resolutions.
DnsServiceDiscovererObserver.DnsResolutionObserver	An observer that provides visibility into DNS resolution results.
DnsServiceDiscovererObserver.ResolutionResult	Results of the current DNS resolution.
DomainSocketAddress	An address which represents a socket belonging to the AF_UNIX socket family.
DuplicateAttributeException	Indicates that a duplicate value was added while constructing a PartitionAttributes.
DuplicateSubscribeException	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.
ElementsAreNonnullByDefault	Indicates that fields, method parameters, method return types, and type parameters within a package are Nonnull unless explicitly annotated with Nullable.
EmbeddedDuplexChannel	EmbeddedChannel that implements DuplexChannel.
EmptyBuffer	An immutable zero capacity Buffer.
EmptyHttpHeaders	HttpHeaders which are always empty and does not allow modification.
EmptySubscriptions	Utility methods for PublisherSource.Subscriptions which don't deliver any data.
EventLoopAwareNettyIoExecutor	A special NettyIoExecutor that exposes the underlying netty EventLoopGroup.
EventLoopAwareNettyIoExecutors	A static factory to create or convert to EventLoopAwareNettyIoExecutor.
ExceptionMapperTest
ExceptionMapperTest.TestApplication
ExceptionMapperTest.TestExceptionMapper
ExecutionContext	Context related to execution and allocation.
ExecutionContextBuilder	A builder of ExecutionContext.
ExecutionContextRule	Test helper that creates and disposes an ExecutionContext for your test case or suite.
ExecutionContextToHttpExecutionContext
ExecutionStrategy	An execution strategy for all transports.
ExecutionStrategyConfigurationFailuresTest
ExecutionStrategyResources
ExecutionStrategyResources.AbstractExecutionStrategyResource
ExecutionStrategyResources.ResourceDefaultStrategy
ExecutionStrategyResources.ResourceInvalidExecStrategy
ExecutionStrategyResources.ResourceRouteExecIdStrategy
ExecutionStrategyResources.ResourceRouteNoOffloadsStrategy
ExecutionStrategyResources.ResourceUnsupportedAsync
ExecutionStrategyTest
ExecutionStrategyTest.TestApplication
ExecutionStrategyTest.TestExecutorStrategy
ExecutionStrategyTest.TestMode
Executor	A general abstraction to execute immediate and delayed tasks.
Executor	A general abstraction to execute immediate and delayed tasks.
ExecutorRule<E extends Executor>	An ExternalResource wrapper for an Executor.
Executors	Utility methods to create various Executors.
FileDescriptorSocketAddress	Special SocketAddress that allows to wrap an already existing filedescriptor.
FilterableGrpcClient	A client to a gRPC service that supports filtering.
FilterableReservedStreamingHttpConnection	A special type of StreamingHttpConnection for the exclusive use of the caller of StreamingHttpClient.reserveConnection(HttpExecutionStrategy, HttpRequestMetaData).
FilterableStreamingHttpClient	A StreamingHttpClient that supports filtering.
FilterableStreamingHttpConnection	A StreamingHttpConnection that supported filtering.
FilterableStreamingHttpLoadBalancedConnection	A FilterableStreamingHttpConnection that supported filtering and implements the LoadBalancedConnection contract.
FixedLevelLogger	A logger that logs at a fixed LogLevel.
FlowControlUtils	A set of utility methods for safe math operations to prevent overflow.
FlushStrategies	A factory for creating FlushStrategy.
FlushStrategy	A strategy that defines how to flush writes on a connection.
FlushStrategy.FlushSender	An abstraction for a FlushStrategy to flush writes by calling FlushStrategy.FlushSender.flush().
FlushStrategy.WriteEventsListener	A listener of write events from the connection on which the related FlushStrategy is applied.
FlushStrategyHolder	A utility class to hold a FlushStrategy and allow it to be updated atomically using FlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider).
FutureUtils	A set of utilities for interacting with Future.
GlobalExecutionContext	ServiceTalk's shared ExecutionContext with reasonable defaults for APIs when a user doesn't provide one.
GlobalFiltersTest
GlobalFiltersTest.TestApplication
GracefulAutoCloseable	An extension of AutoCloseable to add graceful closure semantics.
GroupedPublisher<Key,T>	A group as emitted by Publisher.groupBy(Function, int) or its variants.
GroupedPublisher.QueueSizeProvider	Provide the maximum queue size to use for a particular GroupedPublisher key.
GroupKey<Address>	Identifies a client within a group of clients, and provides enough information to create a client if non exist.
GrpcBindableService<F extends S,S extends GrpcService,FF extends GrpcServiceFilterFactory<F,S>>	A gRPC service that can generate factory instances bound to itself.
GrpcClient<BlockingClient extends BlockingGrpcClient>	A client to a gRPC service.
GrpcClientBuilder<U,R>	A builder for building a gRPC client.
GrpcClientBuilder.MultiClientBuilder	An interface to create multiple gRPC clients sharing the same underlying transport instance.
GrpcClientCallFactory	A factory to create gRPC client call objects for different programming models.
GrpcClientCallFactory.BlockingClientCall<Req,Resp>	An abstraction to make blocking client calls.
GrpcClientCallFactory.BlockingRequestStreamingClientCall<Req,Resp>	An abstraction to make blocking client calls where request is streaming.
GrpcClientCallFactory.BlockingResponseStreamingClientCall<Req,Resp>	An abstraction to make blocking client calls where response is streaming.
GrpcClientCallFactory.BlockingStreamingClientCall<Req,Resp>	An abstraction to make blocking bi-directional streaming client calls.
GrpcClientCallFactory.ClientCall<Req,Resp>	An abstraction to make asynchronous client calls.
GrpcClientCallFactory.RequestStreamingClientCall<Req,Resp>	An abstraction to make asynchronous client calls where request is streaming.
GrpcClientCallFactory.ResponseStreamingClientCall<Req,Resp>	An abstraction to make asynchronous client calls where response is streaming.
GrpcClientCallFactory.StreamingClientCall<Req,Resp>	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>>	A factory for creating clients that follows the specified gRPC GrpcClientFactory contract.
GrpcClientFilterFactory<Filter extends FilterableClient,FilterableClient extends FilterableGrpcClient>	A factory to create gRPC client filters.
GrpcClientMetadata	Metadata for a gRPC client call.
GrpcClients	A factory to create gRPC clients.
GrpcClientSecurityConfigurator<U,R>	Deprecated. Use GrpcClientBuilder.sslConfig(ClientSslConfig).
GrpcExecutionContext	An extension of ExecutionContext for gRPC.
GrpcExecutionStrategies	A factory to create different GrpcExecutionStrategy.
GrpcExecutionStrategies.Builder	A builder to build an HttpExecutionStrategy.
GrpcExecutionStrategy	An execution strategy for gRPC client and servers.
GrpcMetadata	Metadata for a gRPC call.
GrpcPayloadWriter<T>	A PayloadWriter for gRPC.
GrpcRoutes<Service extends GrpcService>	A holder of gRPC routes that constitutes a service.
GrpcRoutes.AllGrpcRoutes	A collection of route corresponding to the enclosing GrpcRoutes.
GrpcRoutes.BlockingRequestStreamingRoute<Req,Resp>	A blocking gRPC route with request streaming.
GrpcRoutes.BlockingResponseStreamingRoute<Req,Resp>	A blocking gRPC route with response streaming.
GrpcRoutes.BlockingRoute<Req,Resp>	A blocking gRPC route.
GrpcRoutes.BlockingStreamingRoute<Req,Resp>	A blocking gRPC route with bi-directional streaming.
GrpcRoutes.RequestStreamingRoute<Req,Resp>	An asynchronous gRPC route with request streaming.
GrpcRoutes.ResponseStreamingRoute<Req,Resp>	An asynchronous gRPC route with response streaming.
GrpcRoutes.Route<Req,Resp>	An asynchronous gRPC route.
GrpcRoutes.StreamingRoute<Req,Resp>	An asynchronous gRPC route with bi-directional streaming.
GrpcSerializationProvider	A provider for gRPC serialization/deserialization.
GrpcServerBuilder	A builder for building a gRPC server.
GrpcServers	A factory to create gRPC servers.
GrpcServerSecurityConfigurator	Deprecated. Use GrpcServerBuilder.sslConfig(ServerSslConfig).
GrpcService	A gRPC service.
GrpcServiceContext	A gRPC service context.
GrpcServiceContext.GrpcProtocol
GrpcServiceFactory<Filter extends Service,Service extends GrpcService,FilterFactory extends GrpcServiceFilterFactory<Filter,Service>>	A factory for binding a gRPC service to a server using a GrpcServiceFactory.ServerBinder.
GrpcServiceFactory.ServerBinder	A utility to bind an HTTP service for gRPC with an appropriate programming model.
GrpcServiceFilterFactory<Filter extends Service,Service>	A factory to create gRPC service filters.
GrpcStatus	Class representing gRPC statuses.
GrpcStatusCode	Standard gRPC status codes.
GrpcStatusException	A GrpcStatus in exception form.
H1ProtocolConfig	Configuration for HTTP/1.1 protocol.
H1ProtocolConfigBuilder	Builder for H1ProtocolConfig.
H1SpecExceptions	Additional exceptions for HTTP/1.1 specification.
H1SpecExceptions.Builder	Builder for H1SpecExceptions.
H2HeadersFactory	A HttpHeadersFactory optimized for HTTP/2.
H2KeepAlivePolicies	A factory to create H2ProtocolConfig.KeepAlivePolicy instances.
H2KeepAlivePolicies.KeepAlivePolicyBuilder	A builder of H2ProtocolConfig.KeepAlivePolicy.
H2ProtocolConfig	Configuration for HTTP/2 protocol.
H2ProtocolConfig.KeepAlivePolicy	A policy for sending PING frames to the peer.
H2ProtocolConfigBuilder	Builder for H2ProtocolConfig.
HeaderUtils
HeaderUtils	Utilities to use for HttpHeaders implementations.
HeaderUtils.CookiesByNameIterator	An Iterator of HttpCookiePair designed to iterate across multiple values of HttpHeaderNames.COOKIE for a specific cookie-name.
HeaderUtils.CookiesIterator	An Iterator of HttpCookiePair designed to iterate across multiple values of HttpHeaderNames.COOKIE.
HexUtils	Utilities for hex strings.
HostAndPort	A tuple of <host name, port>.
HttpApiConversions	Conversion routines to StreamingHttpService.
HttpApiConversions.ServiceAdapterHolder	A holder for StreamingHttpService that adapts another service to the streaming programming model.
HttpClient	Provides a means to issue requests against HTTP service.
HttpClients	Factory methods for building HttpClient (and other API variations) instances.
HttpConnection	Represents a single fixed connection to a HTTP server.
HttpConnectionContext	ConnectionContext for HTTP.
HttpCookiePair	Interface defining a HTTP cookie-pair.
HttpDeserializer<T>	A factory to address deserialization concerns for HTTP request/response payload bodies.
HttpEventKey<T>	A key which identifies a configuration setting for a connection.
HttpExecutionContext	An extension of ExecutionContext for HTTP.
HttpExecutionStrategies	A factory to create different HttpExecutionStrategy.
HttpExecutionStrategies.Builder	A builder to build an HttpExecutionStrategy.
HttpExecutionStrategy	An execution strategy for HTTP client and servers.
HttpExecutionStrategyInfluencer	An entity that wishes to influence HttpExecutionStrategy for an HTTP client or server.
HttpHeaderNames	Common request header names and response header names.
HttpHeaders	HTTP Header Fields.
HttpHeadersFactory	Factory method for creating HttpHeaders.
HttpHeaderValues	Common request header values and response header values.
HttpJerseyRouterBuilder	Builds an StreamingHttpService which routes requests to JAX-RS annotated classes, using Jersey as the routing engine, eg.
HttpLoadBalancerFactory<ResolvedAddress>	A LoadBalancerFactory for HTTP clients.
HttpMetaData	Meta data shared between requests and responses.
HttpOutputStream	The OutputStream which provides access to the HTTP trailers.
HttpPayloadWriter<T>	An interface which mimics behavior like OutputStream, but allows for writing of objects of type HttpPayloadWriter and provides access to the HTTP trailers.
HttpPredicateRouterBuilder	Builds an StreamingHttpService which routes requests to a number of other StreamingHttpServices based on user specified criteria.
HttpProtocolConfig	Defines configuration options for HTTP protocol versions.
HttpProtocolConfigs	Factory methods for HttpProtocolConfigs and builders for their customization.
HttpProtocolVersion	HTTP protocol versioning.
HttpReporter	A Span Reporter that will publish to an HTTP endpoint with a configurable encoding Codec.
HttpReporter.Builder	A builder to create a new HttpReporter.
HttpRequest	An HTTP request.
HttpRequester	Provides a means to make a HTTP request.
HttpRequestFactory	A factory for creating HttpRequests.
HttpRequestMetaData	Meta data associated with an HTTP request.
HttpRequestMetaDataFactory	A static factory class for HttpRequestMetaData objects.
HttpRequestMethod	HTTP Request Methods.
HttpRequestMethod.Properties	Common HTTP Method Properties.
HttpRequestResponseFactory	A combination of HttpRequestFactory and HttpResponseFactory.
HttpRequestUriUtils	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	An HTTP response.
HttpResponseFactory	A factory for creating HttpResponses.
HttpResponseMetaData	Meta data associated with an HTTP response.
HttpResponseMetaDataFactory	A static factory class for HttpResponseMetaData objects.
HttpResponseStatus	Response Status Code.
HttpResponseStatus.StatusClass	The class of response status codes.
HttpSerializationProvider	A provider of HttpSerializers and HttpDeserializers.
HttpSerializationProviders	A factory to create HttpSerializationProviders.
HttpSerializer<T>	A factory to address serialization concerns for HTTP request/response payload bodies.
HttpServerBuilder	A builder for building HTTP Servers.
HttpServers	Factory methods for building HTTP Servers backed by ServerContext.
HttpServerSecurityConfigurator	Deprecated. Use HttpServerBuilder.sslConfig(ServerSslConfig).
HttpService	Same as StreamingHttpService but that accepts HttpRequest and returns HttpResponse.
HttpServiceContext	A HttpConnectionContext for use in the HttpService context.
HttpSetCookie	An interface defining a set-cookie-string.
HttpSetCookie.SameSite	Represents samesite-value for the SameSite attribute.
Identity	Utility class that constructs and provides the default, always supported NOOP 'identity' ContentCodec.
IdleTimeoutInitializer	Initializes the channel with idle timeout handling.
IgnoreConsumedEvent<T>	A ConsumableEvent which ignores IgnoreConsumedEvent.eventConsumed().
IllBehavedRequestFilterTest
IllBehavedRequestFilterTest.IllBehavedRequestFilter
IllBehavedRequestFilterTest.TestApplication
IllegalCharacterException	Exception that clarifies an illegal character and expected values.
InMemoryReference	Represents a reference to another span.
InMemoryScopeManager	A ScopeManager that works with Scope instances.
InMemorySpan	A span that allows reading values at runtime.
InMemorySpanBuilder	A Tracer.SpanBuilder that works with InMemorySpan instances.
InMemorySpanContext	A span that allows reading values at runtime.
InMemorySpanEventListener	Listener for tracing events.
InMemorySpanLog	A entry that corresponds to Span.log(long, String) events.
InMemoryTracer	A Tracer that works with InMemorySpan instances.
InMemoryTraceState	Utility for representing a Ziplin-like trace state.
InMemoryTraceStateFormat<C>	A Format compatible with InMemoryTraceState.
InputConsumingGlobalFiltersTest
InputConsumingGlobalFiltersTest.TestApplication
InterceptorsTest
InterceptorsTest.TestApplication
InvalidRedirectException	Throws when redirect could not be performed.
IoExecutor	Executor that handles IO.
IoThreadFactory	Default ThreadFactory to create IO Threads.
JacksonSerializationProvider	SerializationProvider implementation using jackson.
JdkFlowAdapters	A set of adapter methods for converting to and from JDK Flow APIs and ServiceTalk APIs.
LastHttpMetaData	An indicator that can be attached to the last chunk of payload to carry trailer headers.
LatestValueSubscriber<T>	A PublisherSource.Subscriber which makes the latest value from LatestValueSubscriber.onNext(Object) available outside the context of the PublisherSource.Subscriber.
LegacyTestCompletable	Deprecated. Use TestCompletable instead.
LegacyTestSingle<T>	Deprecated. Use TestSingle instead.
LimitingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactory that limits the total number of active connections created using this ConnectionFactory.
LimitingConnectionFactoryFilter.ConnectionLimiter<ResolvedAddress,C extends ListenableAsyncCloseable>	A contract to limit number of connections created by LimitingConnectionFactoryFilter.
ListenableAsyncCloseable	Provides a way to subscribe when AsyncCloseable.closeAsync() is completed.
LoadBalancedAddress<C extends LoadBalancedConnection>	An address managed by a LoadBalancer.
LoadBalancedConnection	A connection managed by a LoadBalancer.
LoadBalancer<C extends LoadBalancedConnection>	Given multiple SocketAddresses select the most desired SocketAddress to use.
LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>	A factory for creating LoadBalancer instances.
LoadBalancerReadyEvent	A hint from LoadBalancer.eventStream() that the internal state of the LoadBalancer is ready such LoadBalancer.selectConnection(Predicate) is not likely to fail.
LoggerConfig	Logger name + level configuration.
LoggerStringWriter
LoggingCompletableSubscriber	A CompletableSource.Subscriber that wraps another CompletableSource.Subscriber, logging all signals received by the CompletableSource.Subscriber, or sent via the Cancellable.
LoggingPublisherSubscriber<T>	A PublisherSource.Subscriber that wraps another PublisherSource.Subscriber, logging all signals received by the PublisherSource.Subscriber, or sent via the PublisherSource.Subscription.
LoggingReporter	A Simple Reporter that logs the span at INFO level.
LoggingSingleSubscriber<T>	A SingleSource.Subscriber that wraps another SingleSource.Subscriber, logging all signals received by the SingleSource.Subscriber, or sent via the Cancellable.
LogLevel	Defines different severity level of logging.
Main	This class will be invoked by the protoc compiler to create Java ServiceTalk source classes.
Matchers	Custom Matchers specific to http-api.
MathUtils	Internal math utilities.
MaxRequestLimitExceededException	Exception raised when more concurrent requests have been issued on a connection than is allowed.
MaxRequestLimitExceededRejectedSubscribeException	Exception raised when more concurrent requests have been issued on a connection than is allowed.
MessageEncodingException	Exception thrown when a message was encoded with an unsupported encoder.
MixedModeResources
MixedModeResourceTest
MixinAwareParametersRunnerFactory	JUnit supports @Test annotated default methods from v5, this small extension enables it for JUnit 4.
MockFlushStrategy	A mocking setup for FlushStrategy that provides ways to verify interactions with FlushStrategy.WriteEventsListener and also provides access to FlushStrategy.FlushSender.
MultiAddressHttpClientBuilder<U,R>	A builder of StreamingHttpClient instances which have a capacity to call any server based on the parsed absolute-form URL address information from each StreamingHttpRequest.
MultiAddressHttpClientBuilder.SingleAddressInitializer<U,R>	Initializes the SingleAddressHttpClientBuilder for each new client.
MultiAddressHttpClientFilterFactory<U>	A factory for StreamingHttpClientFilter to filter clients for different unresolved addresses.
NettyChannelListenableAsyncCloseable	Implements ListenableAsyncCloseable using a netty Channel.
NettyConnection<Read,Write>	A wrapper over a physical connection providing a way to read/write as a Publisher.
NettyConnectionContext	A specialized ConnectionContext for netty based transports.
NettyConnectionContext.FlushStrategyProvider	A provider of FlushStrategy to update the FlushStrategy for a NettyConnectionContext.
NettyFutureCompletable	A Completable that wraps a netty Future.
NettyIoExecutor	IoExecutor for netty.
NettyIoExecutors	A static factory to create or convert to NettyIoExecutor.
NettyIoExecutors	Factory methods to create IoExecutors using netty as the transport.
NettyPipelineSslUtils	Utilities for ChannelPipeline and SSL/TLS.
NettyServerContext	ServerContext implementation using a netty Channel.
NoAvailableHostException	Thrown when no host is available but at least one is required.
NonResubscribeableCompletableSubscriberFunction	Allows only a single CompletableSource.Subscriber to subscribe to a TestCompletable.
NonResubscribeablePublisherSubscriberFunction<T>	Allows only a single PublisherSource.Subscriber to subscribe to a TestPublisher.
NonResubscribeableSingleSubscriberFunction<T>	Allows only a single SingleSource.Subscriber to subscribe to a TestSingle.
NoOffloadsRouteExecutionStrategy	A special RouteExecutionStrategy that indicates that a resource class or method needs to use a strategy that does not offload user code using a different thread pool.
NoopTransportObserver	Noop version of TransportObserver.
NoopTransportObserver.NoopConnectionObserver	Noop version of ConnectionObserver.
NoopTransportObserver.NoopDataObserver	Noop version of ConnectionObserver.DataObserver.
NoopTransportObserver.NoopMultiplexedObserver	Noop version of ConnectionObserver.MultiplexedObserver.
NoopTransportObserver.NoopReadObserver	Noop version of ConnectionObserver.ReadObserver.
NoopTransportObserver.NoopSecurityHandshakeObserver	Noop version of ConnectionObserver.SecurityHandshakeObserver.
NoopTransportObserver.NoopStreamObserver	Noop version of ConnectionObserver.StreamObserver.
NoopTransportObserver.NoopWriteObserver	Noop version of ConnectionObserver.WriteObserver.
NoopWriteEventsListener	A FlushStrategy.WriteEventsListener that by default does nothing for all method.
OffloaderAwareExecutor	An Executor which is also a SignalOffloaderFactory and hence can influence a specific SignalOffloader used by this Executor.
PartitionAttributes	Provide a way to describe a partition using a collection of of attributes.
PartitionAttributes.Key<T>	A key identifies a specific object in a PartitionAttributes.
PartitionAttributesBuilder	A builder for PartitionAttributes objects.
PartitionedHttpClientBuilder<U,R>	A builder of homogeneous StreamingHttpClient instances which call the server associated with a partition selected from a set of PartitionedServiceDiscovererEvents resolved from a single unresolved address.
PartitionedHttpClientBuilder.SingleAddressInitializer<U,R>	Initializes the SingleAddressHttpClientBuilder for each new client.
PartitionedHttpClientSecurityConfigurator<U,R>	Deprecated. Use PartitionedHttpClientBuilder.appendClientBuilderFilter(PartitionHttpClientBuilderConfigurator).
PartitionedServiceDiscovererEvent<ResolvedAddress>	An ServiceDiscovererEvent which is associated with a partition.
PartitionHttpClientBuilderConfigurator<U,R>	Deprecated. Use PartitionedHttpClientBuilder.SingleAddressInitializer.
PartitionMap<T extends AsyncCloseable>	A map like interface which manages PartitionAttributes that are fully specified and returns the corresponding partitions those PartitionAttributes belong to.
PartitionMapFactory	A generic factory for PartitionMap objects.
PayloadWriter<T>	An interface which mimics behavior like OutputStream, but allows for writing of objects of type PayloadWriter.
PayloadWriterUtils	Utilities for PayloadWriter.
PlatformDependent	Provide utilities that are dependent on the current runtime environment.
PowerSetPartitionMap<T extends AsyncCloseable>	A PartitionMap that creates the full power set using the individual attributes in PartitionAttributeses to create partitions for each PowerSetPartitionMap.add(PartitionAttributes).
PowerSetPartitionMapFactory	A PartitionMapFactory that generates PowerSetPartitionMap type objects.
Processors	Static factory methods for creating processor instances for different type of sources.
ProcessorSignalsConsumer<T>	Consumer of items from a PublisherProcessorSignalsHolder or BlockingProcessorSignalsHolder.
ProtobufSerializationProvider	A SerializationProvider for serializing/deserializing protocol buffer objects.
ProtoBufSerializationProviderBuilder	A builder for building a GrpcSerializationProvider that can serialize and deserialize pre-registered protocol buffer objects.
ProxyResponseException	A proxy response exception, that indicates an unexpected response status from a proxy.
Publisher<T>	An asynchronous computation that produces 0, 1 or more elements and may or may not terminate successfully or with an error.
PublisherFirstStep<T>	Provides the ability to express expectations for the first step in a Subscriber's lifecycle.
PublisherLastStep	Provides the ability to express expectations for the terminal signals (e.g.
PublisherOperator<T,R>	An operator contract for a Publisher.
PublisherProcessorSignalsHolder<T>	A holder of items for a PublisherSource.Processor.
PublisherSource<T>	An asynchronous computation that emits zero or more items to its PublisherSource.Subscriber and may or may not terminate successfully or with an error.
PublisherSource.Processor<T,R>	A PublisherSource.Processor represents a processing stage that is both a PublisherSource and a PublisherSource.Subscriber and obeys the contracts of both.
PublisherSource.Subscriber<T>	A subscriber of result(s) produced by a PublisherSource.
PublisherSource.Subscription	A subscription to control the signals emitted from a PublisherSource to a PublisherSource.Subscriber.
PublisherStep<T>	Provides the ability to express expectations for the PublisherSource.Subscriber.onNext(Object) stages of a Subscriber's lifecycle.
PublisherToSingleOperator<T,R>	An operator contract for a Publisher to Single conversion.
QueueFullAndRejectedSubscribeException	Exception indicating a bounded queue is full, which also resulted in a rejected subscribe.
QueueFullException	Exception indicating a bounded queue is full.
RandomDataUtils
ReactiveStreamsAdapters	A set of adapter methods for converting to and from Reactive Streams APIs and ServiceTalk APIs.
ReadOnlyBufferAllocators	Utility class containing BufferAllocators that create Buffer instances which cannot be modified and are read only.
ReadOnlyClientSecurityConfig	Deprecated. Use ClientSslConfig.
ReadOnlyServerSecurityConfig	Deprecated. Use ServerSslConfig.
ReadOnlyTcpClientConfig	Read only view of TcpClientConfig.
ReadOnlyTcpServerConfig	Read only view of TcpServerConfig.
RedirectingHttpRequesterFilter	A HTTP request filter that performs automatic redirects if StreamingHttpRequester.request(HttpExecutionStrategy, StreamingHttpRequest) method receives 3XX status code in the response.
ReflectionUtils	Provide utilities to assist reflective access.
RejectedSubscribeError	Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is established.
RejectedSubscribeException	Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is established.
RepeatStrategies	A set of strategies to use for repeating with Publisher.repeatWhen(IntFunction), Single.repeatWhen(IntFunction) and Completable.repeatWhen(IntFunction) or in general.
RepeatStrategies.TerminateRepeatException	An Exception instance used to indicate termination of repeats.
RequestConcurrencyController	An interface which allows controlling reserving connections which maybe used concurrently.
RequestConcurrencyController.Result	Result of the RequestConcurrencyController.tryRequest() call.
RequestConcurrencyControllers	Factory for common RequestConcurrencyControllers.
RequestProperties	Helper methods used internally for accessing ServiceTalk-specific request properties.
RequestTargetDecoderHttpServiceFilter	Decodes the HttpRequestMetaData.requestTarget() for each incoming request.
RequestTargetEncoderHttpRequesterFilter	Encodes the HttpRequestMetaData.requestTarget() for each outgoing request.
RequestTargetEncoderHttpServiceFilter	Encodes the HttpRequestMetaData.requestTarget() for each incoming request.
ReservableRequestConcurrencyController	A RequestConcurrencyController that also allows to ReservableRequestConcurrencyController.tryReserve() a connection for exclusive use.
ReservableRequestConcurrencyControllers	Factory for common ReservableRequestConcurrencyControllers.
ReservedBlockingHttpConnection	A special type of BlockingHttpConnection for the exclusive use of the caller of BlockingHttpClient.reserveConnection(HttpRequestMetaData) and BlockingHttpClient.reserveConnection(HttpExecutionStrategy, HttpRequestMetaData).
ReservedBlockingStreamingHttpConnection	A special type of BlockingStreamingHttpConnection for the exclusive use of the caller of BlockingStreamingHttpClient.reserveConnection(HttpRequestMetaData) and BlockingStreamingHttpClient.reserveConnection(HttpExecutionStrategy, HttpRequestMetaData).
ReservedHttpConnection	A special type of HttpConnection for the exclusive use of the caller of HttpClient.reserveConnection(HttpRequestMetaData) and HttpClient.reserveConnection(HttpExecutionStrategy, HttpRequestMetaData).
ReservedStreamingHttpConnection	A special type of StreamingHttpConnection for the exclusive use of the caller of StreamingHttpClient.reserveConnection(HttpRequestMetaData) and StreamingHttpClient.reserveConnection(HttpExecutionStrategy, HttpRequestMetaData).
ReservedStreamingHttpConnectionFilter	A ReservedStreamingHttpConnectionFilter that delegates all methods to a different ReservedStreamingHttpConnectionFilter.
RetryableConnectException	Throws when a connect operations failed.
RetryableException	A marker-interface for exceptions which are safely retryable and occur only before ServiceTalk starts writing a request to the network.
RetryingHttpRequesterFilter	A filter to enable retries for HTTP requests.
RetryingHttpRequesterFilter.Builder	A builder for RetryingHttpRequesterFilter, which puts an upper bound on retry attempts.
RetryStrategies	A set of strategies to use for retrying with Publisher.retryWhen(BiIntFunction), Single.retryWhen(BiIntFunction), and Completable.retryWhen(BiIntFunction) or in general.
RoundRobinLoadBalancer<ResolvedAddress,C extends LoadBalancedConnection>	A LoadBalancer that uses a round robin strategy for selecting addresses.
RoundRobinLoadBalancer.RoundRobinLoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>	LoadBalancerFactory for RoundRobinLoadBalancer.
RouteContinuation	Methods for continuing a route.
RouteExecutionStrategy	Indicates that a resource class or method needs a specific execution strategy.
RouteExecutionStrategyFactory<ES>	A factory that creates an execution strategy for different ids of RouteExecutionStrategy annotation.
RouteExecutionStrategyUtils	Utilities to handle RouteExecutionStrategy annotation.
RouteStarter	Methods for starting a route.
RunnableCompletable
SamplingStrategies	Utility methods for sampling strategies.
ScalarValueSubscription<T>	A PublisherSource.Subscription that only emits a single value.
ScanWithMapper<T,R>	Provides the ability to transform (aka map) signals emitted via the Publisher.scanWith(Supplier) operator.
ScoreSupplier	Enables components to expose a score.
SecurityConfigurator	Deprecated. Use ServerSslConfigBuilder or ClientSslConfigBuilder.
SecurityConfigurator.SslProvider	Deprecated. Use SslProvider.
SecurityFilterTest
SecurityFilterTest.TestApplication
SecurityFilterTest.TestSecurityFilter
SequentialCancellable	A Cancellable that can hold at most one Cancellable that will be cancelled when this is cancelled.
SequentialCompletableSubscriberFunction	Allows multiple CompletableSource.Subscribers to be sequentially subscribed to a TestCompletable.
SequentialDnsServerAddressStreamProvider	A DnsServerAddressStreamProvider which is backed by a sequential list of DNS servers.
SequentialPublisherSubscriberFunction<T>	Allows multiple PublisherSource.Subscribers to be sequentially subscribed to a TestPublisher.
SequentialSingleSubscriberFunction<T>	Allows multiple SingleSource.Subscribers to be sequentially subscribed to a TestSingle.
SerializationException	Exception indicating an error during serialization or deserialization.
SerializationProvider	A provider of serialization implementation for Serializer.
Serializer	A contract for serialization and deserialization.
ServerContext	Context for servers.
ServerSecurityConfig	Deprecated. Use ServerSslConfig.
ServerSecurityConfigurator	Deprecated. Use ServerSslConfigBuilder.
ServerSecurityConfigurator.ClientAuth	Deprecated. Use SslClientAuthMode.
ServerSslConfig	Specifies the configuration for server side TLS/SSL.
ServerSslConfigBuilder	Default builder for ServerSslConfig objects.
ServiceDiscoverer<UnresolvedAddress,ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>	Represents the interaction pattern with a service discovery system.
ServiceDiscovererEvent<ResolvedAddress>	Notification from the Service Discovery system that availability for an address has changed.
ServiceDiscovererUtils	A set of utility functions for ServiceDiscoverer.
ServiceDiscovererUtils.TwoIntsConsumer	Represents an operation that accepts two int-valued arguments and returns no result.
ServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>	A retry strategy for errors emitted from ServiceDiscoverer.discover(Object).
ServiceTalkAutoDiscoverable	AutoDiscoverable registering ServiceTalkFeature if the feature is not already registered.
ServiceTalkFeature	Feature enabling ServiceTalk request handling.
ServiceTalkJacksonSerializerAutoDiscoverable	AutoDiscoverable registering ServiceTalkJacksonSerializerFeature if the feature is not already registered.
ServiceTalkJacksonSerializerFeature	Feature enabling ServiceTalk Jackson serializer request/response content handling.
ServiceTalkSocketOptions	SocketOptions that can be used beside StandardSocketOptions.
ServiceTalkTestTimeout	Standard timeout shared by test classes.
ServiceTalkThreadContextMap	A ThreadContext that provides storage for MDC based upon AsyncContext.
ServiceTalkTracingThreadContextMap	A ThreadContext that provides storage for MDC based upon AsyncContext that also includes tracing information in accessors via AsyncContextInMemoryScopeManager.
SignalOffloader	A contract to offload signals to and from any asynchronous source.
SignalOffloaderFactory	A factory to create new instances of SignalOffloader.
SignalOffloaders	A factory for creating different SignalOffloaders.
Single<T>	An asynchronous computation that either completes with success giving the result or completes with an error.
SingleAddressHttpClientBuilder<U,R>	A builder of StreamingHttpClient instances which call a single server based on the provided unresolved address.
SingleAddressHttpClientSecurityConfigurator<U,R>	Deprecated. Use SingleAddressHttpClientBuilder.sslConfig(ClientSslConfig).
SingleFirstStep<T>	Provides the ability to express expectations for the first step in a Subscriber's lifecycle.
SingleLastStep<T>	Provides the ability to express expectations for the terminal signals (e.g.
SingleLineFormatter	Single-line serialization format.
SingleLineValue	Wrapper for supporting injecting and extracting single-string values.
SingleOperator<T,R>	An operator contract for a Single.
SingleSource<T>	An asynchronous computation that either completes with success giving the result or completes with an error.
SingleSource.Processor<T,R>	A SingleSource.Processor represents a processing stage that is both a SingleSource and a SingleSource.Subscriber and obeys the contracts of both.
SingleSource.Subscriber<T>	Subscriber of the outcome of a SingleSource.
SingleTerminalSignalConsumer<T>	A contract that provides discrete callbacks for various ways in which a SingleSource.Subscriber can terminate.
SingletonDnsServerAddressStreamProvider	A DnsServerAddressStreamProvider which always returns the same DnsServerAddressStream.
Slf4jFixedLevelLoggers	SLF4J implementations of FixedLevelLogger.
SniServerChannelInitializer	SNI ChannelInitializer for servers.
SocketOptionUtils	Utilities to convert SocketOptions.
SourceAdapters	A set of adapter methods to convert an asynchronous source in this module to a corresponding source in io.servicetalk.concurrent module.
SourceWrappers	When request's contents are not buffered, Jersey's determines if the entity body input stream that backs a request can be closed by introspecting the return type of the MessageBodyReader.
SourceWrappers.PublisherSource<T>	A Publisher that is also a Source.
SourceWrappers.SingleSource<T>	A Single that is also a Source.
SplittingFlushStrategy	A FlushStrategy that splits writes into logical write boundaries and manages flush state across those logical write boundaries.
SplittingFlushStrategy.FlushBoundaryProvider	A provider of SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for each written item.
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary	An enumeration for boundary of flushes on which this SplittingFlushStrategy splits writes.
SslClientAuthMode	Indicates the state of the SSLEngine with respect to client authentication.
SslClientChannelInitializer	SSL ChannelInitializer for clients.
SslConfig	Specifies the configuration for TLS/SSL.
SslContextFactory	A factory for creating SslContexts.
SslProvider	The provider to use for SSLEngine.
SslServerChannelInitializer	SSL ChannelInitializer for servers.
StacklessClosedChannelException	ClosedChannelException that will not not fill in the stacktrace but use a cheaper way of producing limited stacktrace details for the user.
StatelessTrailersTransformer<Payload>	An implementation of TrailersTransformer that does not require any state.
StepVerifier	Provides the ability to verify expectations on asynchronous sources.
StepVerifiers	Factory for the first steps that lead to StepVerifier test utility to verify each step in the lifecycle of asynchronous sources Publisher, Single, and Completable.
StrategyInfluencerChainBuilder	A chain of HttpExecutionStrategyInfluencer.
StreamingDeserializer<T>	A contract capable of deserializing a stream of Buffers into a stream of StreamingDeserializers.
StreamingHttpClient	The equivalent of HttpClient but that accepts StreamingHttpRequest and returns StreamingHttpResponse.
StreamingHttpClientFilter	A StreamingHttpClient that delegates all methods to a different StreamingHttpClient.
StreamingHttpClientFilterFactory	A factory for StreamingHttpClientFilter.
StreamingHttpConnection	The equivalent of HttpConnection but that accepts StreamingHttpRequest and returns StreamingHttpResponse.
StreamingHttpConnectionFilter	A StreamingHttpConnection that delegates all methods to a different StreamingHttpConnection.
StreamingHttpConnectionFilterFactory	A factory for StreamingHttpConnectionFilter.
StreamingHttpRequest	The equivalent of HttpRequest but provides the payload as a Publisher.
StreamingHttpRequester	The equivalent of HttpRequester but that accepts StreamingHttpRequest and returns StreamingHttpResponse.
StreamingHttpRequestFactory	A factory for creating StreamingHttpRequests.
StreamingHttpRequestResponseFactory	A combination of StreamingHttpRequestFactory and StreamingHttpResponseFactory.
StreamingHttpRequests	Factory methods for creating StreamingHttpRequests.
StreamingHttpResponse	The equivalent of HttpResponse but provides the payload as a Publisher.
StreamingHttpResponseFactory	A factory for creating StreamingHttpResponses.
StreamingHttpResponses	Factory methods for creating StreamingHttpResponses.
StreamingHttpService	A service contract for the HTTP protocol.
StreamingHttpServiceFilter	An implementation of StreamingHttpService that delegates all methods to the provided StreamingHttpService.
StreamingHttpServiceFilterFactory	A factory for StreamingHttpServiceFilter.
StreamingSerializer	A contract capable of serializing a stream of Objects into a stream of Buffers.
StringMultiValueMatcher	Extends CookieMatcher for things where the value is a string, like headers and query parameters.
SubscribableCompletable	A Completable that is also a CompletableSource and hence can be subscribed.
SubscribablePublisher<T>	A Publisher that is also a PublisherSource and hence can be subscribed.
SubscribableSingle<T>	A Single that is also a SingleSource and hence can be subscribed.
SubscriberUtils	A set of utilities for common PublisherSource.Subscriber tasks.
SynchronousResources	Synchronous (in JAX-RS lingo [1]) resources.
SynchronousResourceTest
TcpClient	A utility to create a TCP clients for tests.
TcpClientChannelInitializer	ChannelInitializer for TCP client.
TcpClientConfig	Configuration for TCP based clients.
TcpConnector	Utility class for TCP clients to connect.
TcpServer	A utility to create a TCP server for tests.
TcpServerBinder	Utility class to start a TCP based server.
TcpServerChannelInitializer	ChannelInitializer for TCP.
TcpServerConfig	Configuration for TCP based servers.
TerminalNotification	Holder of Throwable.
TerminalSignalConsumer	A contract that provides discrete callbacks for various ways in which a PublisherSource.Subscriber or a CompletableSource.Subscriber can terminate.
TestCancellable	A Cancellable that tracks cancellation.
TestCompletable	A Completable & CompletableSource whose outgoing signals to its CompletableSource.Subscribers can be controlled.
TestCompletable.Builder	Allows for creating TestCompletables with non-default settings.
TestCompletableSubscriber	A CompletableSource.Subscriber that enqueues signals and provides blocking methods to consume them.
TestExecutor	An Executor implementation that provides methods for controlling execution of queued and schedules tasks, for testing.
TestHttpServiceContext
TestIterableToBlockingIterable<T>
TestPojo
TestPublisher<T>	A Publisher & PublisherSource whose outgoing signals to its PublisherSource.Subscribers can be controlled.
TestPublisher.Builder<T>	Allows for creating TestPublishers with non-default settings.
TestPublisherSubscriber<T>	A PublisherSource.Subscriber that enqueues TestPublisherSubscriber.onNext(Object) and terminal signals while providing blocking methods to consume these events.
TestSingle<T>	A Single & SingleSource whose outgoing signals to its SingleSource.Subscribers can be controlled.
TestSingle.Builder<T>	Allows for creating TestSingles with non-default settings.
TestSingleSubscriber<T>	A SingleSource.Subscriber that enqueues signals and provides blocking methods to consume them.
TestStreamingHttpClient
TestStreamingHttpConnection
TestSubscription	A PublisherSource.Subscription that tracks requests and cancellation.
TestUtils
TestUtils.ContentReadException
ThreadInterruptingCancellable	A Cancellable that will interrupt a thread.
ThrowableUtils	Utility for creating static Throwables.
TimeoutHttpRequesterFilter	A filter to enable timeouts for HTTP requests.
TracingConstants	Various constants for tracing.
TracingHttpRequesterFilter	An HTTP filter that supports open tracing.
TracingHttpServiceFilter	A StreamingHttpService that supports open tracing.
TrailersTransformer<State,Payload>	A contract for transforming trailers for a streaming HTTP request/response.
TransportObserver	An observer interface that provides visibility into transport events.
TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactoryFilter that configures a TransportObserver for new connections.
TransportObservers	A factory to create different TransportObservers.
TypeHolder<T>	An abstract class to infer ParameterizedTypes for a child class.
UdpReporter	A Span Reporter that will publish to a UDP listener with a configurable encoding Codec.
UdpReporter.Builder	A builder to create a new UdpReporter.
UnknownPartitionException	Thrown when a request is issued but there is no associated partition to send the request to.
UserDataLoggerConfig	LoggerConfig used in areas that can filter logging output to include user data or not.
VerificationTestUtils
Verifiers	Deprecated. Use StepVerifiers instead.
WireLoggingInitializer	A ChannelInitializer that enables wire-logging for all channels.
WriteDemandEstimator	Provides an estimate for the value of n for calls to PublisherSource.Subscription.request(long) per PublisherSource.Subscription.
WriteDemandEstimators	Utility methods associated with WriteDemandEstimator.
ZipContentCodecBuilder	Base class for Zip based content-codecs.
ZipkinHeaderNames	See zipkin documentation.
ZipkinPublisher	A publisher of Spans to the zipkin transport.
ZipkinPublisher.Builder	Builder for ZipkinPublisher.