Package io.servicetalk.transport.netty.internal
-
Interface Summary Interface Description ChannelInitializer Configures aChannel.EventLoopAwareNettyIoExecutor A specialNettyIoExecutorthat exposes the underlying nettyEventLoopGroup.FlushStrategy A strategy that defines how to flush writes on a connection.FlushStrategy.FlushSender An abstraction for aFlushStrategyto flush writes by callingFlushStrategy.FlushSender.flush().FlushStrategy.WriteEventsListener A listener of write events from the connection on which the relatedFlushStrategyisapplied.NettyConnection<Read,Write> A wrapper over a physical connection providing a way to read/write as aPublisher.NettyConnectionContext A specializedConnectionContextfor netty based transports.NettyConnectionContext.FlushStrategyProvider NettyIoExecutor IoExecutorfor netty.SplittingFlushStrategy.FlushBoundaryProvider A provider ofSplittingFlushStrategy.FlushBoundaryProvider.FlushBoundaryfor each written item.WriteDemandEstimator Provides an estimate for the value ofnfor calls toPublisherSource.Subscription.request(long)perPublisherSource.Subscription. -
Class Summary Class Description AddressUtils A utility class to work with addresses.BufferHandler AChannelHandlerthat converts does the following conversions:BuffertoByteBuffor writes.BufferHoldertoByteBuffor writes.ByteBuftoBufferfor reads.ByteBufHoldertoBufferfor reads. This also releases anyByteBufonce converted toBuffer.BuilderUtils Utilities which are used for builders.ByteToMessageDecoder ChannelInboundHandlerAdapterwhich decodes bytes in a stream-like fashion from oneByteBufto an other Message type.ChannelCloseUtils Utilities to handleChannelclosure and its reason.ChannelSet Manages a set ofChannels 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 AChannelInitializerthat registers aConnectionObserverfor all channels.ContextFilterSuccessful Netty pipeline event that represents the successful completion of theConnectionAcceptor.CopyByteBufHandlerChannelInitializer 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.DeferSslHandler AChannelHandlerthat holds a place in a pipeline, allowing us to defer adding theSslHandler.DelegatingFlushStrategy AFlushStrategyimplementation that delegates all calls to anotherFlushStrategy.EmbeddedDuplexChannel EmbeddedChannelthat implementsDuplexChannel.EventLoopAwareNettyIoExecutors A static factory to create or convert toEventLoopAwareNettyIoExecutor.ExecutionContextBuilder A builder ofExecutionContext.ExecutionContextRule Test helper that creates and disposes anExecutionContextfor your test case or suite.FlushStrategies A factory for creatingFlushStrategy.FlushStrategyHolder A utility class to hold aFlushStrategyand allow it to be updated atomically usingFlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider).GlobalExecutionContext ServiceTalk's sharedExecutionContextwith reasonable defaults for APIs when a user doesn't provide one.IdleTimeoutInitializer Initializes the channel with idle timeout handling.IoThreadFactory DefaultThreadFactoryto create IOThreads.MockFlushStrategy A mocking setup forFlushStrategythat provides ways to verify interactions withFlushStrategy.WriteEventsListenerand also provides access toFlushStrategy.FlushSender.NettyChannelListenableAsyncCloseable ImplementsListenableAsyncCloseableusing a nettyChannel.NettyFutureCompletable ACompletablethat wraps a nettyFuture.NettyIoExecutors A static factory to create or convert toNettyIoExecutor.NettyPipelineSslUtils Utilities forChannelPipelineand SSL/TLS.NettyServerContext ServerContextimplementation 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.WriteEventsListenerthat by default does nothing for all method.RandomDataUtils ReadOnlyClientSecurityConfig Deprecated. UseClientSslConfig.ReadOnlyServerSecurityConfig Deprecated. UseServerSslConfig.ServerSecurityConfig Deprecated. UseServerSslConfig.SniServerChannelInitializer SNIChannelInitializerfor servers.SocketOptionUtils Utilities to convertSocketOptions.SplittingFlushStrategy AFlushStrategythat splits writes into logical write boundaries and manages flush state across those logical write boundaries.SslClientChannelInitializer SSLChannelInitializerfor clients.SslContextFactory A factory for creatingSslContexts.SslServerChannelInitializer SSLChannelInitializerfor servers.WireLoggingInitializer AChannelInitializerthat 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 orChannelthat indicates the end of theChanneland no further requests should be attempted.SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary An enumeration for boundary of flushes on which thisSplittingFlushStrategysplits writes. -
Exception Summary Exception Description CloseHandler.CloseEventObservedException ClosedChannelExceptionwith additional meta-data to provide more context on what side initiated the close event.StacklessClosedChannelException ClosedChannelExceptionthat will not not fill in the stacktrace but use a cheaper way of producing limited stacktrace details for the user.