Package io.servicetalk.transport.netty.internal
@ElementsAreNonnullByDefault
package io.servicetalk.transport.netty.internal
-
ClassDescriptionDeprecated.This API is going to be removed in future releases with no planned replacement.Utilities which are used for builders.
ChannelInboundHandlerAdapter
which decodes bytes in a stream-like fashion from oneByteBuf
to an other Message type.Utilities to handleChannel
closure and its reason.Configures aChannel
.Manages a set ofChannel
s to provide a mechanism for closing all of them.Contract between protocol codecs and a close handler.These events indicate an event was observed from the protocol orChannel
that indicates the end of theChannel
and no further requests should be attempted.ClosedChannelException
with additional meta-data to provide more context on what side initiated the close event.Netty UserEvent to indicate the further inbound data should be discarded.CloseHandler.NettyUserEvent
to indicate the end of inbound data was observed at the transport.AChannelInitializer
that registers aConnectionObserver
for all channels.Netty pipeline event that represents the successful completion of theConnectionAcceptor
.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
.Netty UserEvent to signal cancellation of the write stream.Netty UserEvent to signal continuation.AChannelHandler
that holds a place in a pipeline, allowing us to defer adding theSslHandler
.AFlushStrategy
implementation that delegates all calls to anotherFlushStrategy
.A specialNettyIoExecutor
that exposes the underlying nettyEventLoopGroup
.A static factory to create or convert toEventLoopAwareNettyIoExecutor
.ExecutionContextBuilder<ES extends ExecutionStrategy>A builder ofExecutionContext
.Provides utilities around Executors, ExecutionContexts and how they interact with netty Channels.A factory for creatingFlushStrategy
.A strategy that defines how to flush writes on a connection.An abstraction for aFlushStrategy
to flush writes by callingFlushStrategy.FlushSender.flush()
.A listener of write events from the connection on which the relatedFlushStrategy
isapplied
.A utility class to hold aFlushStrategy
and allow it to be updated atomically usingFlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider)
.ServiceTalk's sharedExecutionContext
with reasonable defaults for APIs when a user doesn't provide one.Initializes the channel with idle timeout handling.A contract that defines the connection acceptance criterion.ImplementsListenableAsyncCloseable
using a nettyChannel
.NettyConnection<Read,Write> A wrapper over a physical connection providing a way to read/write as aPublisher
.A specializedConnectionContext
for netty based transports.ACompletable
that wraps a nettyFuture
.IoExecutor
for Netty.A static factory to create or convert toNettyIoExecutor
.DefaultIoThreadFactory
to create IONettyIoThreadFactory.NettyIoThread
s.NettyPipelinedConnection<Req,Resp> Contract for using aNettyConnection
to make pipelined requests, typically for a client.Utilities forChannelPipeline
and SSL/TLS.ServerContext
implementation using a nettyChannel
.Noop version ofTransportObserver
.Noop version ofConnectionObserver
.Noop version ofConnectionObserver.DataObserver
.Noop version ofConnectionObserver.MultiplexedObserver
.Noop version ofConnectionObserver.ProxyConnectObserver
.Noop version ofConnectionObserver.ReadObserver
.Noop version ofConnectionObserver.SecurityHandshakeObserver
.Noop version ofConnectionObserver.StreamObserver
.Noop version ofConnectionObserver.WriteObserver
.AFlushStrategy.WriteEventsListener
that by default does nothing for all method.SNIChannelInitializer
for servers.Utilities to convertSocketOption
s.Deprecated.This class will be removed in the future releases.Deprecated.This interface will be removed in the future releases.An enumeration for boundary of flushes on which thisSplittingFlushStrategy
splits writes.SSLChannelInitializer
for clients.A factory for creatingSslContext
s.SSLChannelInitializer
for servers.ClosedChannelException
that will not fill in the stacktrace but use a cheaper way of producing limited stacktrace details for the user.AChannelInitializer
that enables wire-logging for all channels.Provides an estimate for the value ofn
for calls toPublisherSource.Subscription.request(long)
perPublisherSource.Subscription
.Utility methods associated withWriteDemandEstimator
.