Interface | Description |
---|---|
ChannelInitializer |
Configures a
Channel . |
EventLoopAwareNettyIoExecutor |
A special
NettyIoExecutor that exposes the underlying netty EventLoopGroup . |
FlushStrategy |
A strategy that defines how to flush writes on a connection.
|
FlushStrategy.FlushSender |
An abstraction for a
FlushStrategy to flush writes by calling FlushStrategy.FlushSender.flush() . |
FlushStrategy.WriteEventsListener |
A listener of write events from the connection on which the related
FlushStrategy is
applied . |
NettyConnection<Read,Write> |
A wrapper over a physical connection providing a way to read/write as a
Publisher . |
NettyConnectionContext |
A specialized
ConnectionContext for netty based transports. |
NettyConnectionContext.FlushStrategyProvider | |
NettyIoExecutor |
IoExecutor for netty. |
SplittingFlushStrategy.FlushBoundaryProvider |
A provider of
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for each written item. |
WriteDemandEstimator |
Provides an estimate for the value of
n for calls to PublisherSource.Subscription#request(long) per
PublisherSource.Subscription . |
Class | Description |
---|---|
AddressUtils |
A utility class to work with addresses.
|
BufferHandler |
A
ChannelHandler that converts does the following conversions:
Buffer to ByteBuf for writes.
BufferHolder to ByteBuf for writes.
ByteBuf to Buffer for reads.
ByteBufHolder to Buffer for reads.
This also releases any ByteBuf once converted to Buffer . |
BuilderUtils |
Utilities which are used for builders.
|
ByteToMessageDecoder |
ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an
other Message type. |
ChannelCloseUtils |
Utilities to handle
Channel closure and its reason. |
ChannelSet |
Manages a set of
Channel s 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 |
A
ChannelInitializer that registers a ConnectionObserver for all channels. |
ContextFilterSuccessful |
Netty pipeline event that represents the successful completion of the
ConnectionAcceptor . |
CopyByteBufHandlerChannelInitializer |
Initializer to configure
ChannelInboundHandler that will ensure no pooled ByteBuf s are passed to
the user and so no leaks are produced if the user does not call ReferenceCountUtil.release(Object) . |
DefaultNettyConnection<Read,Write> |
Implementation of
NettyConnection backed by a netty Channel . |
DeferSslHandler |
A
ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler . |
DelegatingFlushStrategy |
A
FlushStrategy implementation that delegates all calls to another FlushStrategy . |
EmbeddedDuplexChannel |
EmbeddedChannel that implements DuplexChannel . |
EventLoopAwareNettyIoExecutors |
A static factory to create or convert to
EventLoopAwareNettyIoExecutor . |
ExecutionContextBuilder |
A builder of
ExecutionContext . |
ExecutionContextRule |
Test helper that creates and disposes an
ExecutionContext for your test case or suite. |
FlushStrategies |
A factory for creating
FlushStrategy . |
FlushStrategyHolder |
A utility class to hold a
FlushStrategy and allow it to be updated atomically using
FlushStrategyHolder.updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider) . |
GlobalExecutionContext |
ServiceTalk's shared
ExecutionContext with reasonable defaults for APIs when a user doesn't provide one. |
IdleTimeoutInitializer |
Initializes the channel with idle timeout handling.
|
IoThreadFactory |
Default
ThreadFactory to create IO Thread s. |
MockFlushStrategy |
A mocking setup for
FlushStrategy that provides ways to verify interactions with WriteEventsListener
and also provides access to FlushSender . |
NettyChannelListenableAsyncCloseable |
Implements
ListenableAsyncCloseable using a netty Channel . |
NettyFutureCompletable |
A
Completable that wraps a netty Future . |
NettyIoExecutors |
A static factory to create or convert to
NettyIoExecutor . |
NettyPipelineSslUtils |
Utilities for
ChannelPipeline and SSL/TLS. |
NettyServerContext |
ServerContext implementation using a netty Channel . |
NoopTransportObserver |
Noop version of
TransportObserver . |
NoopTransportObserver.NoopConnectionObserver |
Noop version of
ConnectionObserver . |
NoopTransportObserver.NoopDataObserver |
Noop version of
ConnectionObserver.DataObserver . |
NoopTransportObserver.NoopMultiplexedObserver |
Noop version of
ConnectionObserver.MultiplexedObserver . |
NoopTransportObserver.NoopReadObserver |
Noop version of
ConnectionObserver.ReadObserver . |
NoopTransportObserver.NoopSecurityHandshakeObserver |
Noop version of
ConnectionObserver.SecurityHandshakeObserver . |
NoopTransportObserver.NoopStreamObserver |
Noop version of
ConnectionObserver.StreamObserver . |
NoopTransportObserver.NoopWriteObserver |
Noop version of
ConnectionObserver.WriteObserver . |
NoopWriteEventsListener |
A
FlushStrategy.WriteEventsListener that 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 convert
SocketOption s. |
SplittingFlushStrategy |
A
FlushStrategy that splits writes into logical write boundaries and manages flush state across those logical
write boundaries. |
SslClientChannelInitializer |
SSL
ChannelInitializer for clients. |
SslContextFactory |
A factory for creating
SslContext s. |
SslServerChannelInitializer |
SSL
ChannelInitializer for servers. |
WireLoggingInitializer |
A
ChannelInitializer that enables wire-logging for all channels. |
WriteDemandEstimators |
Utility methods associated with
WriteDemandEstimator . |
Enum | Description |
---|---|
CloseHandler.CloseEvent |
These events indicate an event was observed from the protocol or
Channel that indicates the end of the
Channel and no further requests should be attempted. |
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary |
An enumeration for boundary of flushes on which this
SplittingFlushStrategy splits writes. |
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. |