Package io.servicetalk.transport.netty.internal
-
Interface Summary Interface Description ChannelInitializer Configures aChannel
.EventLoopAwareNettyIoExecutor A specialNettyIoExecutor
that exposes the underlying nettyEventLoopGroup
.FlushStrategy A strategy that defines how to flush writes on a connection.FlushStrategy.FlushSender An abstraction for aFlushStrategy
to flush writes by callingFlushStrategy.FlushSender.flush()
.FlushStrategy.WriteEventsListener A listener of write events from the connection on which the relatedFlushStrategy
isapplied
.NettyConnection<Read,Write> A wrapper over a physical connection providing a way to read/write as aPublisher
.NettyConnectionContext A specializedConnectionContext
for netty based transports.NettyConnectionContext.FlushStrategyProvider NettyIoExecutor IoExecutor
for netty.SplittingFlushStrategy.FlushBoundaryProvider A provider ofSplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary
for each written item.WriteDemandEstimator Provides an estimate for the value ofn
for calls toPublisherSource.Subscription.request(long)
perPublisherSource.Subscription
. -
Class Summary Class Description AddressUtils A utility class to work with addresses.BufferHandler AChannelHandler
that converts does the following conversions:Buffer
toByteBuf
for writes.BufferHolder
toByteBuf
for writes.ByteBuf
toBuffer
for reads.ByteBufHolder
toBuffer
for reads. This also releases anyByteBuf
once converted toBuffer
.BuilderUtils Utilities which are used for builders.ByteToMessageDecoder ChannelInboundHandlerAdapter
which decodes bytes in a stream-like fashion from oneByteBuf
to an other Message type.ChannelCloseUtils Utilities to handleChannel
closure and its reason.ChannelSet Manages a set ofChannel
s to provide a mechanism for closing all of them.ClientSecurityConfig Deprecated. UseClientSslConfig
.CloseHandler Contract between protocol codecs and a close handler.CloseHandler.DiscardFurtherInboundEvent Netty UserEvent to indicate the further inbound data should be discarded.ConnectionObserverInitializer AChannelInitializer
that registers aConnectionObserver
for all channels.ContextFilterSuccessful Netty pipeline event that represents the successful completion of theConnectionAcceptor
.CopyByteBufHandlerChannelInitializer Initializer to configureChannelInboundHandler
that will ensure no pooledByteBuf
s are passed to the user and so no leaks are produced if the user does not callReferenceCountUtil.release(Object)
.DefaultNettyConnection<Read,Write> Implementation ofNettyConnection
backed by a nettyChannel
.DeferSslHandler AChannelHandler
that holds a place in a pipeline, allowing us to defer adding theSslHandler
.DelegatingFlushStrategy AFlushStrategy
implementation that delegates all calls to anotherFlushStrategy
.EmbeddedDuplexChannel EmbeddedChannel
that implementsDuplexChannel
.EventLoopAwareNettyIoExecutors A static factory to create or convert toEventLoopAwareNettyIoExecutor
.ExecutionContextBuilder A builder ofExecutionContext
.ExecutionContextRule Test helper that creates and disposes anExecutionContext
for your test case or suite.FlushStrategies A factory for creatingFlushStrategy
.FlushStrategyHolder A utility class to hold aFlushStrategy
and allow it to be updated atomically usingFlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider)
.GlobalExecutionContext ServiceTalk's sharedExecutionContext
with reasonable defaults for APIs when a user doesn't provide one.IdleTimeoutInitializer Initializes the channel with idle timeout handling.IoThreadFactory DefaultThreadFactory
to create IOThread
s.MockFlushStrategy A mocking setup forFlushStrategy
that provides ways to verify interactions withFlushStrategy.WriteEventsListener
and also provides access toFlushStrategy.FlushSender
.NettyChannelListenableAsyncCloseable ImplementsListenableAsyncCloseable
using a nettyChannel
.NettyFutureCompletable ACompletable
that wraps a nettyFuture
.NettyIoExecutors A static factory to create or convert toNettyIoExecutor
.NettyPipelineSslUtils Utilities forChannelPipeline
and SSL/TLS.NettyServerContext ServerContext
implementation using a nettyChannel
.NoopTransportObserver Noop version ofTransportObserver
.NoopTransportObserver.NoopConnectionObserver Noop version ofConnectionObserver
.NoopTransportObserver.NoopDataObserver Noop version ofConnectionObserver.DataObserver
.NoopTransportObserver.NoopMultiplexedObserver Noop version ofConnectionObserver.MultiplexedObserver
.NoopTransportObserver.NoopReadObserver Noop version ofConnectionObserver.ReadObserver
.NoopTransportObserver.NoopSecurityHandshakeObserver Noop version ofConnectionObserver.SecurityHandshakeObserver
.NoopTransportObserver.NoopStreamObserver Noop version ofConnectionObserver.StreamObserver
.NoopTransportObserver.NoopWriteObserver Noop version ofConnectionObserver.WriteObserver
.NoopWriteEventsListener AFlushStrategy.WriteEventsListener
that by default does nothing for all method.RandomDataUtils ReadOnlyClientSecurityConfig Deprecated. UseClientSslConfig
.ReadOnlyServerSecurityConfig Deprecated. UseServerSslConfig
.ServerSecurityConfig Deprecated. UseServerSslConfig
.SniServerChannelInitializer SNIChannelInitializer
for servers.SocketOptionUtils Utilities to convertSocketOption
s.SplittingFlushStrategy AFlushStrategy
that splits writes into logical write boundaries and manages flush state across those logical write boundaries.SslClientChannelInitializer SSLChannelInitializer
for clients.SslContextFactory A factory for creatingSslContext
s.SslServerChannelInitializer SSLChannelInitializer
for servers.WireLoggingInitializer AChannelInitializer
that enables wire-logging for all channels.WriteDemandEstimators Utility methods associated withWriteDemandEstimator
. -
Enum Summary Enum Description CloseHandler.CloseEvent These events indicate an event was observed from the protocol orChannel
that indicates the end of theChannel
and no further requests should be attempted.SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary An enumeration for boundary of flushes on which thisSplittingFlushStrategy
splits writes. -
Exception Summary Exception Description CloseHandler.CloseEventObservedException ClosedChannelException
with additional meta-data to provide more context on what side initiated the close event.StacklessClosedChannelException ClosedChannelException
that will not not fill in the stacktrace but use a cheaper way of producing limited stacktrace details for the user.