Package io.servicetalk.transport.netty.internal

@ElementsAreNonnullByDefault package io.servicetalk.transport.netty.internal

Related Packages

Package	Description
io.servicetalk.transport.netty

Class	Description
BufferHandler	Deprecated. This API is going to be removed in future releases with no planned replacement.
BuilderUtils	Utilities which are used for builders.
ByteToMessageDecoder	ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an other Message type.
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.
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.
CloseHandler.InboundDataEndEvent	CloseHandler.NettyUserEvent to indicate the end of inbound data was observed at the transport.
ConnectionObserverInitializer	A ChannelInitializer that registers a ConnectionObserver for all channels.
ContextFilterSuccessful	Netty pipeline event that represents the successful completion of the ConnectionAcceptor.
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).
DefaultNettyConnection<Read,Write>	Implementation of NettyConnection backed by a netty Channel.
DefaultNettyConnection.CancelWriteUserEvent	Netty UserEvent to signal cancellation of the write stream.
DefaultNettyConnection.ContinueUserEvent	Netty UserEvent to signal continuation.
DeferSslHandler	A ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler.
DelegatingFlushStrategy	A FlushStrategy implementation that delegates all calls to another FlushStrategy.
EventLoopAwareNettyIoExecutor	A special NettyIoExecutor that exposes the underlying netty EventLoopGroup.
EventLoopAwareNettyIoExecutors	A static factory to create or convert to EventLoopAwareNettyIoExecutor.
ExecutionContextBuilder<ES extends ExecutionStrategy>	A builder of ExecutionContext.
ExecutionContextUtils	Provides utilities around Executors, ExecutionContexts and how they interact with netty Channels.
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).
GlobalExecutionContext	ServiceTalk's shared ExecutionContext with reasonable defaults for APIs when a user doesn't provide one.
IdleTimeoutInitializer	Initializes the channel with idle timeout handling.
InfluencerConnectionAcceptor	A contract that defines the connection acceptance criterion.
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.
NettyIoThreadFactory	Default IoThreadFactory to create IO NettyIoThreadFactory.NettyIoThreads.
NettyPipelinedConnection<Req,Resp>	Contract for using a NettyConnection to make pipelined requests, typically for a client.
NettyPipelineSslUtils	Utilities for ChannelPipeline and SSL/TLS.
NettyServerContext	ServerContext implementation using a netty Channel.
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.NoopProxyConnectObserver	Noop version of ConnectionObserver.ProxyConnectObserver.
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.
SniServerChannelInitializer	SNI ChannelInitializer for servers.
SocketOptionUtils	Utilities to convert SocketOptions.
SplittingFlushStrategy	Deprecated. This class will be removed in the future releases.
SplittingFlushStrategy.FlushBoundaryProvider	Deprecated. This interface will be removed in the future releases.
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary	An enumeration for boundary of flushes on which this SplittingFlushStrategy splits writes.
SslClientChannelInitializer	SSL ChannelInitializer for clients.
SslContextFactory	A factory for creating SslContexts.
SslServerChannelInitializer	SSL ChannelInitializer for servers.
StacklessClosedChannelException	ClosedChannelException that will not fill in the stacktrace but use a cheaper way of producing limited stacktrace details for the user.
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.