Top Inners Fields Constructors Methods
io.rsocket.loadbalance

pack-priv Class RSocketPool

extends ResolvingOperator<Object>
implements CoreSubscriber<List<LoadbalanceTarget>>, Closeable
Class Inheritance
All Implemented Interfaces
io.rsocket.Closeable, reactor.core.Disposable, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber
Imports
io.netty.util.ReferenceCountUtil, io.rsocket.Closeable, .Payload, .RSocket, io.rsocket.core.RSocketConnector, io.rsocket.frame.FrameType, java.util.Arrays, .Collection, .HashMap, .Iterator, .List, .ListIterator, java.util.concurrent.CancellationException, java.util.concurrent.atomic.AtomicReferenceFieldUpdater, java.util.stream.Collectors, org.reactivestreams.Publisher, .Subscription, reactor.core.CoreSubscriber, reactor.core.publisher.Flux, .Mono, .Operators, .Sinks, reactor.util.annotation.Nullable

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
RSocketPool.DeferredResolutionRSocket

pack-priv static class
RSocketPool.FluxInner<INPUT>

pack-priv static class
RSocketPool.MonoInner<T>

pack-priv static class
RSocketPool.WrappingList

Field Summary

Modifier and TypeField and Description
pack-priv static final AtomicReferenceFieldUpdater<RSocketPool, PooledRSocket[]>
ACTIVE_SOCKETS

pack-priv volatile PooledRSocket[]
activeSockets

pack-priv final RSocketConnector
connector

pack-priv final RSocketPool.DeferredResolutionRSocket
deferredResolutionRSocket

pack-priv static final PooledRSocket[]
EMPTY

pack-priv final LoadbalanceStrategy
loadbalanceStrategy

pack-priv final Sinks.Empty<Void>
onAllClosedSink

pack-priv static final AtomicReferenceFieldUpdater<RSocketPool, Subscription>
S

pack-priv volatile Subscription
s

pack-priv static final PooledRSocket[]
TERMINATED

Hides io.rsocket.loadbalance.ResolvingOperator.TERMINATED.

Inherited from io.rsocket.loadbalance.ResolvingOperator:
ADDED_STATEEMPTY_SUBSCRIBEDEMPTY_UNSUBSCRIBEDON_DISPOSEREADYREADY_STATEsubscribersSUBSCRIBERStTERMINATED_STATEvaluewipWIP

Constructor Summary

AccessConstructor and Description
public
RSocketPool(RSocketConnector connector, Publisher<List<LoadbalanceTarget>> targetPublisher, LoadbalanceStrategy loadbalanceStrategy)

Method Summary

Modifier and TypeMethod and Description
protected void
doOnDispose()

Overrides io.rsocket.loadbalance.ResolvingOperator.doOnDispose.

pack-priv RSocket
doSelect()

public Mono<Void>
onClose()

Implements io.rsocket.Closeable.onClose.

Returns a Mono that terminates when the instance is terminated by any reason.
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(List<LoadbalanceTarget>
the element signaled
targets)

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).
pack-priv RSocket
select()

Inherited from io.rsocket.loadbalance.ResolvingOperator:
addblockcompleteconnectdisposedoFinallydoOnValueExpireddoOnValueResolveddoSubscribeinvalidateisDisposedisPendingobserveremoveterminatevalueIfResolved