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.
ChannelInboundHandlerAdapterwhich decodes bytes in a stream-like fashion from oneByteBufto an other Message type.Utilities to handleChannelclosure and its reason.Configures aChannel.Manages a set ofChannels 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 orChannelthat indicates the end of theChanneland no further requests should be attempted.ClosedChannelExceptionwith 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.NettyUserEventto indicate the end of inbound data was observed at the transport.AChannelInitializerthat registers aConnectionObserverfor all channels.Netty pipeline event that represents the successful completion of theConnectionAcceptor.Initializer to configureChannelInboundHandlerthat will ensure no pooledByteBufs are passed to the user and so no leaks are produced if the user does not callReferenceCountUtil.release(Object).DefaultNettyConnection<Read,Write> Implementation ofNettyConnectionbacked by a nettyChannel.Netty UserEvent to signal cancellation of the write stream.Netty UserEvent to signal continuation.AChannelHandlerthat holds a place in a pipeline, allowing us to defer adding theSslHandler.Deprecated.this class will be made package-private in the future releases.A specialNettyIoExecutorthat 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 aFlushStrategyto flush writes by callingFlushStrategy.FlushSender.flush().A listener of write events from the connection on which the relatedFlushStrategyisapplied.A utility class to hold aFlushStrategyand allow it to be updated atomically usingFlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider).ServiceTalk's sharedExecutionContextwith 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.ImplementsListenableAsyncCloseableusing a nettyChannel.NettyConnection<Read,Write> A wrapper over a physical connection providing a way to read/write as aPublisher.A specializedConnectionContextfor netty based transports.ACompletablethat wraps a nettyFuture.IoExecutorfor Netty.A static factory to create or convert toNettyIoExecutor.DefaultIoThreadFactoryto create IONettyIoThreadFactory.NettyIoThreads.NettyPipelinedConnection<Req,Resp> Contract for using aNettyConnectionto make pipelined requests, typically for a client.Utilities forChannelPipelineand SSL/TLS.ServerContextimplementation using a nettyChannel.Deprecated.Starting from version 0.42.58ConnectionObserverprovides default implementations for all of its callbacks, making the need in this class less relevant.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.WriteEventsListenerthat by default does nothing for all method.SNIChannelInitializerfor servers.Utilities to convertSocketOptions.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 thisSplittingFlushStrategysplits writes.SSLChannelInitializerfor clients.A factory for creatingSslContexts.SSLChannelInitializerfor servers.ClosedChannelExceptionthat will not fill in the stacktrace but use a cheaper way of producing limited stacktrace details for the user.AChannelInitializerthat enables wire-logging for all channels.Provides an estimate for the value ofnfor calls toPublisherSource.Subscription.request(long)perPublisherSource.Subscription.Utility methods associated withWriteDemandEstimator.