Modifier and Type	Class and Description
pack-priv static class	FluxSwitchMapNoPrefetch.SwitchMapInner<T, R>
pack-priv static class	FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>

Modifier and Type	Field and Description
pack-priv static long	COMPLETED_MASK
pack-priv static long	HAS_REQUEST_MASK
pack-priv static int	HAS_REQUEST_OFFSET
pack-priv static int	INDEX_OFFSET
pack-priv static long	INNER_COMPLETED_MASK
pack-priv static long	INNER_SUBSCRIBED_MASK
pack-priv static long	INNER_WIP_MASK
pack-priv final Function<? super T, ? extends Publisher<? extends R>>	mapper
pack-priv static int	MAX_HAS_REQUEST
pack-priv static long	TERMINATED

Access	Constructor and Description
pack-priv	FluxSwitchMapNoPrefetch(Flux<? extends T> source, Function<? super T, ? extends Publisher<? extends R>> mapper)

Method Summary

Modifier and Type	Method and Description
pack-priv static long	Returns: next state addRequest(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, long received from `Operators#addCap` method. previousRequested) Atomically add increment hasRequest value to indicate that we added capacity to `SwitchMapMain#requested` Note, If the given `previousRequested` param value is greater than zero it works as an indicator that in some scenarios prevents setting HasRequest to 1.
public int	getPrefetch() Overrides reactor.core.publisher.Flux.getPrefetch. The prefetch configuration of the `Flux`
pack-priv static boolean	hasInnerCompleted(long state)
pack-priv static boolean	hasMainCompleted(long state)
pack-priv static int	hasRequest(long state)
pack-priv static long	Returns: previous state incrementIndex(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically increment the index of the active inner subscriber.
pack-priv static int	index(long state)
pack-priv static boolean	isInnerSubscribed(long state)
pack-priv static boolean	isWip(long state)
pack-priv static int	nextIndex(long state)
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.
pack-priv static long	Returns: previous state setInnerCompleted(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically set the inner completed flag.
pack-priv static long	Returns: previous state setInnerSubscribed(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex) Atomically set a bit on the current state indicating that current inner has received a subscription.
pack-priv static long	Returns: previous state setMainCompleted(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically set main completed flag.
pack-priv static long	Returns: previous state setTerminated(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically set state as terminated
pack-priv static long	Returns: previous state setWip(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex) Atomically set WIP flag to indicate that we do some work from Inner#OnNext or Inner#OnComplete.
pack-priv static long	Returns: encoded state state(int index, boolean wip, int hasRequest, boolean innerSubscribed, boolean mainCompleted, boolean innerCompleted) Generic method to encode state from the given params into a long value
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.
pack-priv static long	Returns: previous state unsetWip(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex, boolean isDemandFulfilled, int expectedRequest) Atomically unset WIP flag to indicate that we have done the work from Inner#OnNext If the current state is `TERMINATED` or the index is one equals to expected then the flag will not be set

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

Field Detail

COMPLETED_MASK	back to summary
pack-priv static long COMPLETED_MASK

HAS_REQUEST_MASK	back to summary
pack-priv static long HAS_REQUEST_MASK

HAS_REQUEST_OFFSET	back to summary
pack-priv static int HAS_REQUEST_OFFSET

INDEX_OFFSET	back to summary
pack-priv static int INDEX_OFFSET

INNER_COMPLETED_MASK	back to summary
pack-priv static long INNER_COMPLETED_MASK

INNER_SUBSCRIBED_MASK	back to summary
pack-priv static long INNER_SUBSCRIBED_MASK

INNER_WIP_MASK	back to summary
pack-priv static long INNER_WIP_MASK

mapper	back to summary
pack-priv final Function<? super T, ? extends Publisher<? extends R>> mapper

MAX_HAS_REQUEST	back to summary
pack-priv static int MAX_HAS_REQUEST

TERMINATED	back to summary
pack-priv static long TERMINATED

Constructor Detail

FluxSwitchMapNoPrefetch	back to summary
pack-priv FluxSwitchMapNoPrefetch(Flux<? extends T> source, Function<? super T, ? extends Publisher<? extends R>> mapper)

Method Detail

addRequest back to summary

addRequest	back to summary
pack-priv static long addRequest(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, long previousRequested) Atomically add increment hasRequest value to indicate that we added capacity to `SwitchMapMain#requested` Note, If the given `previousRequested` param value is greater than zero it works as an indicator that in some scenarios prevents setting HasRequest to 1. Due to racing nature, the `SwitchMapMain#requested` may be incremented but the following addRequest may be delayed. That will lead that Inner may read the new value and request more data from the inner upstream. In turn, the delay may be that big that inner may fulfill new demand and set hasRequest to 0 faster that addRequest happens and leave `SwitchMapMain#requested` at zero as well. Thus, we use previousRequested to check if inner was requested, and if it was, we assume the explained case happened and newly added demand was already fulfilled Parameters previousRequested:long received from `Operators#addCap` method. Returns:long next state

pack-priv static long addRequest(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, long previousRequested)

Atomically add increment hasRequest value to indicate that we added capacity to SwitchMapMain#requested

Note, If the given previousRequested param value is greater than zero it works as an indicator that in some scenarios prevents setting HasRequest to 1. Due to racing nature, the SwitchMapMain#requested may be incremented but the following addRequest may be delayed. That will lead that Inner may read the new value and request more data from the inner upstream. In turn, the delay may be that big that inner may fulfill new demand and set hasRequest to 0 faster that addRequest happens and leave SwitchMapMain#requested at zero as well. Thus, we use previousRequested to check if inner was requested, and if it was, we assume the explained case happened and newly added demand was already fulfilled

Parameters

previousRequested:long: received from Operators#addCap method.

Returns:long

next state

getPrefetch back to summary

getPrefetch	back to summary
public int getPrefetch() Overrides reactor.core.publisher.Flux.getPrefetch. Doc from reactor.core.publisher.Flux.getPrefetch. The prefetch configuration of the `Flux` Returns:int the prefetch configuration of the `Flux`, -1 if unspecified Annotations @Override

public int getPrefetch()

Overrides reactor.core.publisher.Flux.getPrefetch.

Doc from reactor.core.publisher.Flux.getPrefetch.

The prefetch configuration of the Flux

Returns:int

the prefetch configuration of the Flux, -1 if unspecified

Annotations

@Override

hasInnerCompleted	back to summary
pack-priv static boolean hasInnerCompleted(long state)

hasMainCompleted	back to summary
pack-priv static boolean hasMainCompleted(long state)

hasRequest	back to summary
pack-priv static int hasRequest(long state)

incrementIndex back to summary

incrementIndex	back to summary
pack-priv static long incrementIndex(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically increment the index of the active inner subscriber. The index will not be changed if the current state is `TERMINATED` Returns:long previous state

pack-priv static long incrementIndex(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance)

Atomically increment the index of the active inner subscriber. The index will not be changed if the current state is TERMINATED

Returns:long: previous state

index	back to summary
pack-priv static int index(long state)

isInnerSubscribed	back to summary
pack-priv static boolean isInnerSubscribed(long state)

isWip	back to summary
pack-priv static boolean isWip(long state)

nextIndex	back to summary
pack-priv static int nextIndex(long state)

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Overrides reactor.core.publisher.InternalFluxOperator.scanUnsafe. Implements reactor.core.Scannable.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override

public Object scanUnsafe(Scannable.Attr<T> key)

Overrides reactor.core.publisher.InternalFluxOperator.scanUnsafe.

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override

setInnerCompleted back to summary

setInnerCompleted	back to summary
pack-priv static long setInnerCompleted(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically set the inner completed flag. The flag will not be set if the current state is `TERMINATED` Returns:long previous state

pack-priv static long setInnerCompleted(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance)

Atomically set the inner completed flag. The flag will not be set if the current state is TERMINATED

Returns:long: previous state

setInnerSubscribed	back to summary
pack-priv static long setInnerSubscribed(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex) Atomically set a bit on the current state indicating that current inner has received a subscription. If the index has changed during the subscription or stream was cancelled, the bit will not bit set Returns:long previous state

setInnerSubscribed

back to summary

pack-priv static long setInnerSubscribed(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex)

Atomically set a bit on the current state indicating that current inner has received a subscription. If the index has changed during the subscription or stream was cancelled, the bit will not bit set

Returns:long: previous state

setMainCompleted back to summary

setMainCompleted	back to summary
pack-priv static long setMainCompleted(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically set main completed flag. The flag will not be set if the current state is `TERMINATED` Returns:long previous state

pack-priv static long setMainCompleted(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance)

Atomically set main completed flag. The flag will not be set if the current state is TERMINATED

Returns:long: previous state

setTerminated	back to summary
pack-priv static long setTerminated(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance) Atomically set state as terminated Returns:long previous state

setTerminated

back to summary

pack-priv static long setTerminated(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance)

Atomically set state as terminated

Returns:long: previous state

setWip back to summary

setWip	back to summary
pack-priv static long setWip(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex) Atomically set WIP flag to indicate that we do some work from Inner#OnNext or Inner#OnComplete. If the current state is `TERMINATED` or the index is one equals to expected then the flag will not be set Returns:long previous state

pack-priv static long setWip(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex)

Atomically set WIP flag to indicate that we do some work from Inner#OnNext or Inner#OnComplete. If the current state is TERMINATED or the index is one equals to expected then the flag will not be set

Returns:long: previous state

state	back to summary
pack-priv static long state(int index, boolean wip, int hasRequest, boolean innerSubscribed, boolean mainCompleted, boolean innerCompleted) Generic method to encode state from the given params into a long value Returns:long encoded state

state

back to summary

pack-priv static long state(int index, boolean wip, int hasRequest, boolean innerSubscribed, boolean mainCompleted, boolean innerCompleted)

Generic method to encode state from the given params into a long value

Returns:long: encoded state

subscribeOrReturn back to summary

subscribeOrReturn	back to summary
public CoreSubscriber<? super T> subscribeOrReturn(CoreSubscriber<? super R> actual) Implements abstract reactor.core.publisher.InternalFluxOperator.subscribeOrReturn. Implements reactor.core.publisher.OptimizableOperator.subscribeOrReturn. Doc from reactor.core.publisher.OptimizableOperator.subscribeOrReturn. Allow delegation of the subscription by returning a `CoreSubscriber`, or force subscription encapsulation by returning null. This can be used in conjunction with `nextOptimizableSource()` to perform subscription in a loop instead of by recursion. Returns:CoreSubscriber<? super T> next `CoreSubscriber` or "null" if the subscription was already done inside the method Annotations @Override

public CoreSubscriber<? super T> subscribeOrReturn(CoreSubscriber<? super R> actual)

Implements abstract reactor.core.publisher.InternalFluxOperator.subscribeOrReturn.

Implements reactor.core.publisher.OptimizableOperator.subscribeOrReturn.

Doc from reactor.core.publisher.OptimizableOperator.subscribeOrReturn.

Allow delegation of the subscription by returning a CoreSubscriber, or force subscription encapsulation by returning null. This can be used in conjunction with nextOptimizableSource() to perform subscription in a loop instead of by recursion.

Returns:CoreSubscriber<? super T>

next CoreSubscriber or "null" if the subscription was already done inside the method

Annotations

@Override

unsetWip back to summary

unsetWip	back to summary
pack-priv static long unsetWip(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex, boolean isDemandFulfilled, int expectedRequest) Atomically unset WIP flag to indicate that we have done the work from Inner#OnNext If the current state is `TERMINATED` or the index is one equals to expected then the flag will not be set Returns:long previous state

pack-priv static long unsetWip(FluxSwitchMapNoPrefetch.SwitchMapMain<?, ?> instance, int expectedIndex, boolean isDemandFulfilled, int expectedRequest)

Atomically unset WIP flag to indicate that we have done the work from Inner#OnNext If the current state is TERMINATED or the index is one equals to expected then the flag will not be set

Returns:long: previous state

reactor.core.publisher back to summary

pack-priv final Class FluxSwitchMapNoPrefetch.SwitchMapInner<T, R>

Class Inheritance

extends Object
implements InnerConsumer<R>

java.lang.Object
reactor.core.publisher.FluxSwitchMapNoPrefetch.SwitchMapInner

All Implemented Interfaces

reactor.core.publisher.InnerConsumer, reactor.core.Scannable, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final CoreSubscriber<? super R>	actual
pack-priv boolean	done
pack-priv final int	index
pack-priv final StateLogger	logger
pack-priv T	nextElement
pack-priv FluxSwitchMapNoPrefetch.SwitchMapInner<T, R>	nextInner
pack-priv final FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>	parent
pack-priv long	produced
pack-priv long	requested
pack-priv Subscription	s

Constructor Summary

Access	Constructor and Description
pack-priv	SwitchMapInner(FluxSwitchMapNoPrefetch.SwitchMapMain<T, R> parent, CoreSubscriber<? super R> actual, int index, StateLogger logger)

Method Summary

Modifier and Type	Method and Description
pack-priv void	cancelFromParent()
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`.
pack-priv boolean	isCancelledByParent()
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(R the element signaled t) 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 void	request(long n)
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

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

Field Detail

actual	back to summary
pack-priv final CoreSubscriber<? super R> actual

done	back to summary
pack-priv boolean done

index	back to summary
pack-priv final int index

logger	back to summary
pack-priv final StateLogger logger Annotations @Nullable

nextElement	back to summary
pack-priv T nextElement

nextInner	back to summary
pack-priv FluxSwitchMapNoPrefetch.SwitchMapInner<T, R> nextInner

parent	back to summary
pack-priv final FluxSwitchMapNoPrefetch.SwitchMapMain<T, R> parent

produced	back to summary
pack-priv long produced

requested	back to summary
pack-priv long requested

s	back to summary
pack-priv Subscription s

Constructor Detail

SwitchMapInner	back to summary
pack-priv SwitchMapInner(FluxSwitchMapNoPrefetch.SwitchMapMain<T, R> parent, CoreSubscriber<? super R> actual, int index, StateLogger logger)

Method Detail

cancelFromParent	back to summary
pack-priv void cancelFromParent()

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

isCancelledByParent	back to summary
pack-priv boolean isCancelledByParent()

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

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

onNext back to summary

public void onNext(R t)

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

t:R: the element signaled

Annotations

@Override

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

request	back to summary
pack-priv void request(long n)

scanUnsafe back to summary

public Object scanUnsafe(Scannable.Attr<T> key)

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

reactor.core.publisher back to summary

pack-priv final Class FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>

Class Inheritance

extends Object
implements InnerOperator<T, R>

java.lang.Object
reactor.core.publisher.FluxSwitchMapNoPrefetch.SwitchMapMain

All Implemented Interfaces

reactor.core.publisher.InnerOperator, reactor.core.publisher.InnerProducer, org.reactivestreams.Subscription, reactor.core.Scannable, reactor.core.publisher.InnerConsumer, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final CoreSubscriber<? super R>	actual
pack-priv boolean	done
pack-priv FluxSwitchMapNoPrefetch.SwitchMapInner<T, R>	inner
pack-priv final StateLogger	logger
pack-priv final Function<? super T, ? extends Publisher<? extends R>>	mapper
pack-priv volatile long	requested
pack-priv static final AtomicLongFieldUpdater<FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>>	REQUESTED
pack-priv Subscription	s
pack-priv volatile long	state
pack-priv static final AtomicLongFieldUpdater<FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>>	STATE
pack-priv volatile Throwable	throwable
pack-priv static final AtomicReferenceFieldUpdater<FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>, Throwable>	THROWABLE

Constructor Summary

Access	Constructor and Description
pack-priv	SwitchMapMain(CoreSubscriber<? super R> actual, Function<? super T, ? extends Publisher<? extends R>> mapper)
pack-priv	SwitchMapMain(CoreSubscriber<? super R> actual, Function<? super T, ? extends Publisher<? extends R>> mapper, StateLogger logger)

Method Summary

Modifier and Type	Method and Description
public final CoreSubscriber<? super R>	actual() Implements reactor.core.publisher.InnerProducer.actual.
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
public Stream<? extends Scannable>	inners() Overrides default reactor.core.Scannable.inners. Return a `Stream` of referenced inners (flatmap, multicast etc)
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(T the element signaled t) 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)`.
public void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides default reactor.core.publisher.InnerProducer.scanUnsafe. Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
pack-priv void	subscribeInner(T nextElement, FluxSwitchMapNoPrefetch.SwitchMapInner<T, R> nextInner, int nextIndex)

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

Field Detail

actual	back to summary
pack-priv final CoreSubscriber<? super R> actual

done	back to summary
pack-priv boolean done

inner	back to summary
pack-priv FluxSwitchMapNoPrefetch.SwitchMapInner<T, R> inner

logger	back to summary
pack-priv final StateLogger logger Annotations @Nullable

mapper	back to summary
pack-priv final Function<? super T, ? extends Publisher<? extends R>> mapper

requested	back to summary
pack-priv volatile long requested

REQUESTED	back to summary
pack-priv static final AtomicLongFieldUpdater<FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>> REQUESTED Annotations @SuppressWarnings:rawtypes

s	back to summary
pack-priv Subscription s

state	back to summary
pack-priv volatile long state

STATE	back to summary
pack-priv static final AtomicLongFieldUpdater<FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>> STATE Annotations @SuppressWarnings:rawtypes

throwable	back to summary
pack-priv volatile Throwable throwable

THROWABLE	back to summary
pack-priv static final AtomicReferenceFieldUpdater<FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>, Throwable> THROWABLE Annotations @SuppressWarnings:rawtypes

Constructor Detail

SwitchMapMain	back to summary
pack-priv SwitchMapMain(CoreSubscriber<? super R> actual, Function<? super T, ? extends Publisher<? extends R>> mapper)

SwitchMapMain	back to summary
pack-priv SwitchMapMain(CoreSubscriber<? super R> actual, Function<? super T, ? extends Publisher<? extends R>> mapper, StateLogger logger)

Method Detail

actual

back to summary

public final CoreSubscriber<? super R> actual()

Implements reactor.core.publisher.InnerProducer.actual.

Annotations

@Override

cancel back to summary

public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

inners back to summary

public Stream<? extends Scannable> inners()

Overrides default reactor.core.Scannable.inners.

Doc from reactor.core.Scannable.inners.

Return a Stream of referenced inners (flatmap, multicast etc)

Returns:Stream<? extends Scannable>

a Stream of referenced inners (flatmap, multicast etc)

Annotations

@Override

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

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

onNext back to summary

public void onNext(T t)

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

t:T: the element signaled

Annotations

@Override

onSubscribe back to summary

public void onSubscribe(Subscription s)

Implements reactor.core.CoreSubscriber.onSubscribe.

Doc from reactor.core.CoreSubscriber.onSubscribe.

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

request back to summary

public void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

scanUnsafe back to summary

public Object scanUnsafe(Scannable.Attr<T> key)

Overrides default reactor.core.publisher.InnerProducer.scanUnsafe.

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

subscribeInner	back to summary
pack-priv void subscribeInner(T nextElement, FluxSwitchMapNoPrefetch.SwitchMapInner<T, R> nextInner, int nextIndex)

pack-priv final Class FluxSwitchMapNoPrefetch<T, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class FluxSwitchMapNoPrefetch.SwitchMapInner<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class FluxSwitchMapNoPrefetch.SwitchMapMain<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail