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 Client security configuration.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 Read-only security config for clients.ReadOnlyServerSecurityConfig Read-only security config for servers.ServerSecurityConfig Server security configuration.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.