Reactor Core 3.6.0 · reactor.core.publisher.FluxSwitchOnFirst

Modifier and Type	Class and Description
pack-priv abstract static class	FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R>
pack-priv static class	FluxSwitchOnFirst.SwitchOnFirstConditionalControlSubscriber<T>
pack-priv static class	FluxSwitchOnFirst.SwitchOnFirstConditionalMain<T, R>
pack-priv static class	FluxSwitchOnFirst.SwitchOnFirstControlSubscriber<T>
pack-priv static class	FluxSwitchOnFirst.SwitchOnFirstMain<T, R>

Field Summary

Modifier and Type	Field and Description
pack-priv final boolean	cancelSourceOnComplete
pack-priv static final int	HAS_FIRST_VALUE_RECEIVED_FLAG
pack-priv static final int	HAS_FIRST_VALUE_SENT_FLAG
pack-priv static final int	HAS_INBOUND_CANCELLED_FLAG
pack-priv static final int	HAS_INBOUND_CLOSED_PREMATURELY_FLAG
pack-priv static final int	HAS_INBOUND_REQUESTED_ONCE_FLAG
pack-priv static final int	HAS_INBOUND_SUBSCRIBED_ONCE_FLAG
pack-priv static final int	HAS_INBOUND_SUBSCRIBER_SET_FLAG
pack-priv static final int	HAS_INBOUND_TERMINATED_FLAG
pack-priv static final int	HAS_OUTBOUND_CANCELLED_FLAG
pack-priv static final int	HAS_OUTBOUND_SUBSCRIBED_FLAG
pack-priv static final int	HAS_OUTBOUND_TERMINATED_FLAG
pack-priv final BiFunction<Signal<? extends T>, Flux<T>, Publisher<? extends R>>	transformer

Inherited from reactor.core.publisher.InternalFluxOperator:: optimizableOperator

Access	Constructor and Description
pack-priv	FluxSwitchOnFirst(Flux<? extends T> source, BiFunction<Signal<? extends T>, Flux<T>, Publisher<? extends R>> transformer, boolean cancelSourceOnComplete)

Method Summary

Modifier and Type	Method and Description
public int	getPrefetch() Overrides reactor.core.publisher.Flux.getPrefetch. The prefetch configuration of the `Flux`
pack-priv static boolean	hasFirstValueReceived(long state)
pack-priv static boolean	hasFirstValueSent(long state)
pack-priv static boolean	hasInboundCancelled(long state)
pack-priv static boolean	hasInboundClosedPrematurely(long state)
pack-priv static boolean	hasInboundRequestedOnce(long state)
pack-priv static boolean	hasInboundSubscribedOnce(long state)
pack-priv static boolean	hasInboundSubscriberSet(long state)
pack-priv static boolean	hasInboundTerminated(long state)
pack-priv static boolean	hasOutboundCancelled(long state)
pack-priv static boolean	hasOutboundSubscribed(long state)
pack-priv static boolean	hasOutboundTerminated(long state)
pack-priv static <T, R> long	Returns: previous observed state markFirstValueReceived(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the first inbound onNext signal has already been received.
pack-priv static <T, R> long	Returns: previous observed state markFirstValueSent(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the first onNext value has been successfully delivered.
pack-priv static <T, R> long	Returns: previous observed state markInboundCancelled(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the inbound has already been cancelled.
pack-priv static <T, R> long	Returns: previous observed state markInboundCancelledAndOutboundTerminated(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds flags which indicate that the inbound has cancelled upstream and errored the outbound downstream.
pack-priv static <T, R> long	Returns: previous observed state markInboundClosedPrematurely(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds flags which indicate that the inbound has prematurely from the very bottom of the pipe.
pack-priv static <T, R> long	Returns: previous observed state markInboundRequestedOnce(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the inbound has already been requested once.
pack-priv static <T, R> long	Returns: previous observed state markInboundSubscribedOnce(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the inbound has already been subscribed once.
pack-priv static <T, R> long	Returns: previous observed state markInboundSubscriberSet(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the inbound subscriber has already been set.
pack-priv static <T, R> long	Returns: previous observed state markInboundTerminated(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the inbound has already been terminated with onComplete or onError.
pack-priv static <T, R> long	Returns: previous observed state markOutboundCancelled(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the outbound has already been cancelled.
pack-priv static <T, R> long	Returns: previous observed state markOutboundSubscribed(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the outbound has received subscription.
pack-priv static <T, R> long	Returns: previous observed state markOutboundTerminated(FluxSwitchOnFirst.AbstractSwitchOnFirstMain<T, R> instance) Adds a flag which indicate that the outbound has already been terminated with onComplete or onError.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides reactor.core.publisher.InternalFluxOperator.scanUnsafe. Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public CoreSubscriber<? super T>	subscribeOrReturn(CoreSubscriber<? super R> actual) Implements abstract reactor.core.publisher.InternalFluxOperator.subscribeOrReturn. Implements reactor.core.publisher.OptimizableOperator.subscribeOrReturn. Allow delegation of the subscription by returning a `CoreSubscriber`, or force subscription encapsulation by returning null.

Inherited from reactor.core.publisher.InternalFluxOperator:: nextOptimizableSource source subscribe

pack-priv final Class FluxSwitchOnFirst<T, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary