Top Description Inners Fields Constructors Methods
reactor.netty5.transport

public final Class TransportConnector

extends Object
Class Inheritance
Imports
io.netty5.channel.Channel, .ChannelFactory, .ChannelInitializer, .ChannelOption, .EventLoop, .EventLoopGroup, .ServerChannelFactory, io.netty5.channel.socket.DomainSocketAddress, .SocketProtocolFamily, io.netty5.resolver.AddressResolver, .AddressResolverGroup, io.netty5.util.AttributeKey, io.netty5.util.concurrent.Future, .Promise, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, reactor.core.publisher.Mono, reactor.netty5.Connection, reactor.util.Logger, .Loggers, reactor.util.annotation.Nullable, reactor.util.context.Context, .ContextView, reactor.util.retry.Retry, java.net.ProtocolFamily, .SocketAddress, java.util.Collections, .List, .Map, .Objects, java.util.concurrent.atomic.AtomicInteger, .AtomicReferenceFieldUpdater, java.util.function.Predicate, .Supplier
TransportConnector is a helper class that creates, initializes and registers the channel. It performs the actual connect operation to the remote peer or binds the channel.
Authors
Stephane Maldini, Violeta Georgieva
Since
1.0.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
TransportConnector.MonoChannelPromise

pack-priv static class
TransportConnector.RetryConnectException

Field Summary

Modifier and TypeField and Description
pack-priv static final AttributeKey<ContextView>
CONTEXT_VIEW

pack-priv static final Logger
log

pack-priv static final Predicate<Throwable>
RETRY_PREDICATE

Constructor Summary

AccessConstructor and Description
pack-priv
TransportConnector()

Method Summary

Modifier and TypeMethod and Description
public static Mono<Channel>

Returns:

a Mono of Channel
bind(TransportConfig
the transport configuration
config, ChannelInitializer<Channel>
the ChannelInitializer that will be used for initializing the channel pipeline
channelInitializer, SocketAddress
the local address
bindAddress, boolean
true if domain socket is needed, false otherwise
isDomainSocket)

Binds a Channel.

public static Mono<Channel>

Returns:

a Mono of Channel
connect(TransportConfig
the transport configuration
config, SocketAddress
the SocketAddress to connect to
remoteAddress, AddressResolverGroup<?>
the resolver which will resolve the address of the unresolved named address
resolverGroup, ChannelInitializer<Channel>
the ChannelInitializer that will be used for initializing the channel pipeline
channelInitializer)

Connect a Channel to the remote peer.

public static Mono<Channel>

Returns:

a Mono of Channel
connect(TransportConfig
the transport configuration
config, SocketAddress
the SocketAddress to connect to
remoteAddress, AddressResolverGroup<?>
the resolver which will resolve the address of the unresolved named address
resolverGroup, ChannelInitializer<Channel>
the ChannelInitializer that will be used for initializing the channel pipeline
channelInitializer, ContextView
the current ContextView
contextView)

Connect a Channel to the remote peer.

public static Mono<Channel>

Returns:

a Mono of Channel
connect(TransportConfig
the transport configuration
config, SocketAddress
the SocketAddress to connect to
remoteAddress, AddressResolverGroup<?>
the resolver which will resolve the address of the unresolved named address
resolverGroup, ChannelInitializer<Channel>
the ChannelInitializer that will be used for initializing the channel pipeline
channelInitializer, EventLoop
the EventLoop to use for handling the channel.
eventLoop)

Connect a Channel to the remote peer.

public static Mono<Channel>

Returns:

a Mono of Channel
connect(TransportConfig
the transport configuration
config, SocketAddress
the SocketAddress to connect to
remoteAddress, AddressResolverGroup<?>
the resolver which will resolve the address of the unresolved named address
resolverGroup, ChannelInitializer<Channel>
the ChannelInitializer that will be used for initializing the channel pipeline
channelInitializer, EventLoop
the EventLoop to use for handling the channel.
eventLoop, ContextView
the current ContextView
contextView)

Connect a Channel to the remote peer.

pack-priv static void
doConnect(List<SocketAddress> addresses, Supplier<? extends SocketAddress> bindAddress, TransportConnector.MonoChannelPromise connectPromise, int index)

pack-priv static Mono<Channel>
doInitAndRegister(TransportConfig config, ChannelInitializer<Channel> channelInitializer, boolean isDomainSocket, EventLoop eventLoop)

pack-priv static Mono<Channel>
doResolveAndConnect(Channel channel, TransportConfig config, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup, ContextView contextView)

pack-priv static void
setAttributes(Channel
the channel
channel, Map<AttributeKey<?>, ?>
the attributes
attrs)

Set the channel attributes

pack-priv static void
setChannelOptions(Channel
the channel
channel, Map<ChannelOption<?>, ?>
the options
options, boolean isDomainSocket)

Set the channel options

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait