Modifier and Type	Class and Description
pack-priv static class	NewConnectionProvider.DisposableConnect
pack-priv static class	NewConnectionProvider.NewConnectionObserver

Modifier and Type	Field and Description
pack-priv static final NewConnectionProvider	INSTANCE
pack-priv static final Logger	log

Access	Constructor and Description
pack-priv	NewConnectionProvider()

Modifier and Type	Method and Description
public Mono<? extends Connection>	acquire(TransportConfig the transport configuration config, ConnectionObserver the `ConnectionObserver` observer, Supplier<? extends SocketAddress> the `SocketAddress` to connect to remoteAddress, AddressResolverGroup<?> the resolver which will resolve the address of the unresolved named address resolverGroup) Implements reactor.netty5.resources.ConnectionProvider.acquire. Return an existing or new `Connection` on subscribe.
public boolean	isDisposed() Overrides default reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed.
public int	maxConnections() Overrides default reactor.netty5.resources.ConnectionProvider.maxConnections. Returns the maximum number of connections before starting pending

INSTANCE	back to summary
pack-priv static final NewConnectionProvider INSTANCE

log	back to summary
pack-priv static final Logger log

NewConnectionProvider	back to summary
pack-priv NewConnectionProvider()

Method Detail

acquire back to summary

acquire	back to summary
public Mono<? extends Connection> acquire(TransportConfig config, ConnectionObserver observer, Supplier<? extends SocketAddress> remoteAddress, AddressResolverGroup<?> resolverGroup) Implements reactor.netty5.resources.ConnectionProvider.acquire. Doc from reactor.netty5.resources.ConnectionProvider.acquire. Return an existing or new `Connection` on subscribe. Parameters config:TransportConfig the transport configuration observer:ConnectionObserver the `ConnectionObserver` remoteAddress:Supplier<? extends SocketAddress> the `SocketAddress` to connect to resolverGroup:AddressResolverGroup<?> the resolver which will resolve the address of the unresolved named address Returns:Mono<? extends Connection> an existing or new `Mono` of `Connection` Annotations @Override

public Mono<? extends Connection> acquire(TransportConfig config, ConnectionObserver observer, Supplier<? extends SocketAddress> remoteAddress, AddressResolverGroup<?> resolverGroup)

Implements reactor.netty5.resources.ConnectionProvider.acquire.

Doc from reactor.netty5.resources.ConnectionProvider.acquire.

Return an existing or new Connection on subscribe.

Parameters

config:TransportConfig: the transport configuration
observer:ConnectionObserver: the ConnectionObserver
remoteAddress:Supplier<? extends SocketAddress>: the SocketAddress to connect to
resolverGroup:AddressResolverGroup<?>: the resolver which will resolve the address of the unresolved named address

Returns:Mono<? extends Connection>

an existing or new Mono of Connection

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Overrides default reactor.core.Disposable.isDisposed. Doc from reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed. Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed. Returns:boolean true when there's a guarantee the resource or task is disposed. Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations

@Override

maxConnections	back to summary
public int maxConnections() Overrides default reactor.netty5.resources.ConnectionProvider.maxConnections. Doc from reactor.netty5.resources.ConnectionProvider.maxConnections. Returns the maximum number of connections before starting pending Returns:int the maximum number of connections before starting pending Annotations @Override

maxConnections

back to summary

public int maxConnections()

Overrides default reactor.netty5.resources.ConnectionProvider.maxConnections.

Doc from reactor.netty5.resources.ConnectionProvider.maxConnections.

Returns the maximum number of connections before starting pending

Returns:int

the maximum number of connections before starting pending

Annotations

@Override

reactor.netty5.resources back to summary

pack-priv final Class NewConnectionProvider.DisposableConnect

Class Inheritance

extends Object
implements CoreSubscriber<Channel>, Disposable

java.lang.Object
reactor.netty5.resources.NewConnectionProvider.DisposableConnect

All Implemented Interfaces

reactor.core.Disposable, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final Supplier<? extends SocketAddress>	bindAddress
pack-priv final Context	currentContext
pack-priv final MonoSink<Connection>	sink
pack-priv Subscription	subscription

Constructor Summary

Access	Constructor and Description
pack-priv	DisposableConnect(MonoSink<Connection> sink, Supplier<? extends SocketAddress> bindAddress)

Method Summary

Modifier and Type	Method and Description
public Context	currentContext() Overrides default reactor.core.CoreSubscriber.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`.
public void	dispose() Implements reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource.
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onError(Throwable the throwable signaled t) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(Channel the element signaled channel) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bindAddress	back to summary
pack-priv final Supplier<? extends SocketAddress> bindAddress

currentContext	back to summary
pack-priv final Context currentContext

sink	back to summary
pack-priv final MonoSink<Connection> sink

subscription	back to summary
pack-priv Subscription subscription

Constructor Detail

DisposableConnect	back to summary
pack-priv DisposableConnect(MonoSink<Connection> sink, Supplier<? extends SocketAddress> bindAddress)

Method Detail

currentContext back to summary

currentContext	back to summary
public Context currentContext() Overrides default reactor.core.CoreSubscriber.currentContext. Doc from reactor.core.CoreSubscriber.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`. Returns:Context a resolved context or `Context#empty()` Annotations @Override

public Context currentContext()

Overrides default reactor.core.CoreSubscriber.currentContext.

Doc from reactor.core.CoreSubscriber.currentContext.

Request a Context from dependent components which can include downstream operators during subscribing or a terminal org.reactivestreams.Subscriber.

Returns:Context

a resolved context or Context#empty()

Annotations

@Override

dispose	back to summary
public void dispose() Implements reactor.core.Disposable.dispose. Doc from reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource. Implementations are required to make this method idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations

@Override

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements org.reactivestreams.Subscriber.onComplete. Doc from org.reactivestreams.Subscriber.onComplete. Successful terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Annotations @Override

public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable t) Implements org.reactivestreams.Subscriber.onError. Doc from org.reactivestreams.Subscriber.onError. Failed terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Parameters t:Throwable the throwable signaled Annotations @Override

public void onError(Throwable t)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

t:Throwable: the throwable signaled

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(Channel channel) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters channel:Channel the element signaled Annotations @Override

public void onNext(Channel channel)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

channel:Channel: the element signaled

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Implements reactor.core.CoreSubscriber.onSubscribe. Doc from reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`. Should further `onNext` related state modification occur, thread-safety will be required. Note that an invalid request `<= 0` will not produce an onError and will simply be ignored or reported through a debug-enabled `reactor.util.Logger`. Invoked after calling `Publisher#subscribe(Subscriber)`. No data will start flowing until `Subscription#request(long)` is invoked. It is the responsibility of this `Subscriber` instance to call `Subscription#request(long)` whenever more data is wanted. The `Publisher` will send notifications only in response to `Subscription#request(long)`. Parameters s:Subscription Doc from org.reactivestreams.Subscriber.onSubscribe. the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(Subscription s)

Implements reactor.core.CoreSubscriber.onSubscribe.

Doc from reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by onNext(Object) before calling Subscription#request(long). Should further onNext related state modification occur, thread-safety will be required.

Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled reactor.util.Logger. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

s:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

reactor.netty5.resources back to summary

pack-priv final Class NewConnectionProvider.NewConnectionObserver

Class Inheritance

extends Object
implements ConnectionObserver

java.lang.Object
reactor.netty5.resources.NewConnectionProvider.NewConnectionObserver

All Implemented Interfaces

reactor.netty5.ConnectionObserver

Field Summary

Modifier and Type	Field and Description
pack-priv final Context	currentContext
pack-priv final ConnectionObserver	obs
pack-priv final MonoSink<Connection>	sink

Constructor Summary

Access	Constructor and Description
pack-priv	NewConnectionObserver(MonoSink<Connection> sink, ConnectionObserver obs)

Method Summary

Modifier and Type	Method and Description
public Context	currentContext() Overrides default reactor.netty5.ConnectionObserver.currentContext. Connection listener `Context`
public void	onStateChange(Connection the connection reference connection, ConnectionObserver.State the new State newState) Implements reactor.netty5.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response)
public void	onUncaughtException(Connection the remote connection c, Throwable the failing cause error) Overrides default reactor.netty5.ConnectionObserver.onUncaughtException. React on connection fatal error, will request a disconnecting state change by default.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

currentContext	back to summary
pack-priv final Context currentContext

obs	back to summary
pack-priv final ConnectionObserver obs

sink	back to summary
pack-priv final MonoSink<Connection> sink

Constructor Detail

NewConnectionObserver	back to summary
pack-priv NewConnectionObserver(MonoSink<Connection> sink, ConnectionObserver obs)

Method Detail

currentContext back to summary

currentContext	back to summary
public Context currentContext() Overrides default reactor.netty5.ConnectionObserver.currentContext. Doc from reactor.netty5.ConnectionObserver.currentContext. Connection listener `Context` Returns:Context current `Context` or `Context#empty()` Annotations @Override

public Context currentContext()

Overrides default reactor.netty5.ConnectionObserver.currentContext.

Doc from reactor.netty5.ConnectionObserver.currentContext.

Connection listener Context

Returns:Context

current Context or Context#empty()

Annotations

@Override

onStateChange	back to summary
public void onStateChange(Connection connection, ConnectionObserver.State newState) Implements reactor.netty5.ConnectionObserver.onStateChange. Doc from reactor.netty5.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response) Parameters connection:Connection the connection reference newState:ConnectionObserver.State the new State Annotations @Override

onStateChange

back to summary

public void onStateChange(Connection connection, ConnectionObserver.State newState)

Implements reactor.netty5.ConnectionObserver.onStateChange.

Doc from reactor.netty5.ConnectionObserver.onStateChange.

React on connection state change (e.g. http request or response)

Parameters

connection:Connection: the connection reference
newState:ConnectionObserver.State: the new State

Annotations

@Override

onUncaughtException back to summary

onUncaughtException	back to summary
public void onUncaughtException(Connection c, Throwable error) Overrides default reactor.netty5.ConnectionObserver.onUncaughtException. Doc from reactor.netty5.ConnectionObserver.onUncaughtException. React on connection fatal error, will request a disconnecting state change by default. It should only catch exceptions that can't be consumed by a `NettyInbound#receive` subscriber. Parameters c:Connection the remote connection error:Throwable the failing cause Annotations @Override

public void onUncaughtException(Connection c, Throwable error)

Overrides default reactor.netty5.ConnectionObserver.onUncaughtException.

Doc from reactor.netty5.ConnectionObserver.onUncaughtException.

React on connection fatal error, will request a disconnecting state change by default. It should only catch exceptions that can't be consumed by a NettyInbound#receive subscriber.

Parameters

c:Connection: the remote connection
error:Throwable: the failing cause

Annotations

@Override

pack-priv final Class NewConnectionProvider

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class NewConnectionProvider.DisposableConnect

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class NewConnectionProvider.NewConnectionObserver

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail