Modifier and Type	Class and Description
pack-priv static class	FluxTapFuseable.TapConditionalFuseableSubscriber<T>
pack-priv static class	FluxTapFuseable.TapFuseableSubscriber<T>

Modifier and Type	Field and Description
pack-priv final STATE	commonTapState
pack-priv final SignalListenerFactory<T, STATE>	tapFactory

Access	Constructor and Description
pack-priv	FluxTapFuseable(Flux<? extends T> source, SignalListenerFactory<T, STATE> tapFactory)

Modifier and Type	Method and Description
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 T> 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.

commonTapState	back to summary
pack-priv final STATE commonTapState

tapFactory	back to summary
pack-priv final SignalListenerFactory<T, STATE> tapFactory

FluxTapFuseable	back to summary
pack-priv FluxTapFuseable(Flux<? extends T> source, SignalListenerFactory<T, STATE> tapFactory)

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 @Nullable @Override

subscribeOrReturn	back to summary
public CoreSubscriber<? super T> subscribeOrReturn(CoreSubscriber<? super T> actual) throws Throwable 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

Modifier and Type	Field and Description
pack-priv final Fuseable.ConditionalSubscriber<? super T>	actualConditional

Access	Constructor and Description
public	TapConditionalFuseableSubscriber(Fuseable.ConditionalSubscriber<? super T> actual, SignalListener<T> signalListener, Context ctx)

Modifier and Type	Method and Description
public boolean	tryOnNext(T the value to consume, not null t) Implements reactor.core.Fuseable.ConditionalSubscriber.tryOnNext. Try consuming the value and return true if successful.

actualConditional	back to summary
pack-priv final Fuseable.ConditionalSubscriber<? super T> actualConditional

TapConditionalFuseableSubscriber	back to summary
public TapConditionalFuseableSubscriber(Fuseable.ConditionalSubscriber<? super T> actual, SignalListener<T> signalListener, Context ctx)

tryOnNext	back to summary
public boolean tryOnNext(T t) Implements reactor.core.Fuseable.ConditionalSubscriber.tryOnNext. Doc from reactor.core.Fuseable.ConditionalSubscriber.tryOnNext. Try consuming the value and return true if successful. Parameters t:T the value to consume, not null Returns:boolean true if consumed, false if dropped and a new value can be immediately sent Annotations @Override

pack-priv Class FluxTapFuseable.TapFuseableSubscriber<T>

Class Inheritance

extends FluxTap.TapSubscriber<T>
implements Fuseable.QueueSubscription<T>

java.lang.Object
reactor.core.publisher.FluxTap.TapSubscriber
reactor.core.publisher.FluxTapFuseable.TapFuseableSubscriber

All Implemented Interfaces

reactor.core.Fuseable.QueueSubscription, org.reactivestreams.Subscription, java.util.Queue, java.util.Collection, java.lang.Iterable

Known Direct Subclasses

reactor.core.publisher.FluxTapFuseable.TapConditionalFuseableSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv int	mode
pack-priv Fuseable.QueueSubscription<T>	qs

Inherited from reactor.core.publisher.FluxTap.TapSubscriber:: actual context done listener s

Constructor Summary

Access	Constructor and Description
pack-priv	TapFuseableSubscriber(CoreSubscriber<? super T> actual, SignalListener<T> signalListener, Context ctx)

Method Summary

Modifier and Type	Method and Description
public void	clear() Implements java.util.Collection.clear. Removes all of the elements from this collection (optional operation).
protected RuntimeException	handleObserverErrorInPoll(Throwable the exception thrown from a handler method listenerError) Cancel the active subscription, pass the listener error to `SignalListener#handleListenerError(Throwable)` then return that same exception wrapped via `Exceptions#propagate(Throwable)` if needed.
protected RuntimeException	handleObserverErrorMultipleInPoll(Throwable the exception thrown from a handler method listenerError, RuntimeException the exception that was about to be thrown from poll when handler was invoked pollError) Cancel the active subscription, pass the listener error to `SignalListener#handleListenerError(Throwable)`, combine it with the original error and then return the combined exception.
public boolean	isEmpty() Implements java.util.Collection.isEmpty. Returns `true` if this collection contains no elements.
public void	onNext(T the element signaled t) Overrides reactor.core.publisher.FluxTap.TapSubscriber.onNext. 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) Overrides reactor.core.publisher.FluxTap.TapSubscriber.onSubscribe. Implements reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`.
public T	poll() Implements java.util.Queue.poll. Retrieves and removes the head of this queue, or returns `null` if this queue is empty.
public int	requestFusion(int the mode requested by the intermediate operator requestedMode) Implements reactor.core.Fuseable.QueueSubscription.requestFusion. Request a specific fusion mode from this QueueSubscription.
public int	size() Implements java.util.Collection.size. Returns the number of elements in this collection.

Inherited from reactor.core.publisher.FluxTap.TapSubscriber:: actual cancel currentContext handleListenerErrorAndTerminate handleListenerErrorMultipleAndTerminate handleListenerErrorPostTermination handleListenerErrorPreSubscription onComplete onError request scanUnsafe

Field Detail

mode	back to summary
pack-priv int mode

qs	back to summary
pack-priv Fuseable.QueueSubscription<T> qs

Constructor Detail

TapFuseableSubscriber	back to summary
pack-priv TapFuseableSubscriber(CoreSubscriber<? super T> actual, SignalListener<T> signalListener, Context ctx)

Method Detail

clear	back to summary
public void clear() Implements java.util.Collection.clear. Doc from java.util.Collection.clear. Removes all of the elements from this collection (optional operation). The collection will be empty after this method returns. Annotations @Override

clear

back to summary

public void clear()

Implements java.util.Collection.clear.

Doc from java.util.Collection.clear.

Removes all of the elements from this collection (optional operation). The collection will be empty after this method returns.

Annotations

@Override

handleObserverErrorInPoll back to summary

handleObserverErrorInPoll	back to summary
protected RuntimeException handleObserverErrorInPoll(Throwable listenerError) Cancel the active subscription, pass the listener error to `SignalListener#handleListenerError(Throwable)` then return that same exception wrapped via `Exceptions#propagate(Throwable)` if needed. It should be immediately thrown to terminate the downstream directly from `poll()` (without invoking any other handler). Parameters listenerError:Throwable the exception thrown from a handler method

protected RuntimeException handleObserverErrorInPoll(Throwable listenerError)

Cancel the active subscription, pass the listener error to SignalListener#handleListenerError(Throwable) then return that same exception wrapped via Exceptions#propagate(Throwable) if needed. It should be immediately thrown to terminate the downstream directly from poll() (without invoking any other handler).

Parameters

listenerError:Throwable: the exception thrown from a handler method

handleObserverErrorMultipleInPoll back to summary

handleObserverErrorMultipleInPoll	back to summary
protected RuntimeException handleObserverErrorMultipleInPoll(Throwable listenerError, RuntimeException pollError) Cancel the active subscription, pass the listener error to `SignalListener#handleListenerError(Throwable)`, combine it with the original error and then return the combined exception. The returned exception should be immediately thrown to terminate the downstream directly from `poll()` (without invoking any other handler). Parameters listenerError:Throwable the exception thrown from a handler method pollError:RuntimeException the exception that was about to be thrown from poll when handler was invoked

protected RuntimeException handleObserverErrorMultipleInPoll(Throwable listenerError, RuntimeException pollError)

Cancel the active subscription, pass the listener error to SignalListener#handleListenerError(Throwable), combine it with the original error and then return the combined exception. The returned exception should be immediately thrown to terminate the downstream directly from poll() (without invoking any other handler).

Parameters

listenerError:Throwable: the exception thrown from a handler method
pollError:RuntimeException: the exception that was about to be thrown from poll when handler was invoked

isEmpty back to summary

isEmpty	back to summary
public boolean isEmpty() Implements java.util.Collection.isEmpty. Doc from java.util.Collection.isEmpty. Returns `true` if this collection contains no elements. Returns:boolean `true` if this collection contains no elements Annotations @Override

public boolean isEmpty()

Implements java.util.Collection.isEmpty.

Doc from java.util.Collection.isEmpty.

Returns true if this collection contains no elements.

Returns:boolean

true if this collection contains no elements

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Overrides reactor.core.publisher.FluxTap.TapSubscriber.onNext. 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 @SuppressWarnings:ConstantConditions @Override

public void onNext(T t)

Overrides reactor.core.publisher.FluxTap.TapSubscriber.onNext.

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

@SuppressWarnings:ConstantConditions
@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Overrides reactor.core.publisher.FluxTap.TapSubscriber.onSubscribe. 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)

Overrides reactor.core.publisher.FluxTap.TapSubscriber.onSubscribe.

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

poll back to summary

poll	back to summary
public T poll() Implements java.util.Queue.poll. Doc from java.util.Queue.poll. Retrieves and removes the head of this queue, or returns `null` if this queue is empty. Returns:T the head of this queue, or `null` if this queue is empty Annotations @Override @Nullable

public T poll()

Implements java.util.Queue.poll.

Doc from java.util.Queue.poll.

Retrieves and removes the head of this queue, or returns null if this queue is empty.

Returns:T

the head of this queue, or null if this queue is empty

Annotations

@Override
@Nullable

requestFusion	back to summary
public int requestFusion(int requestedMode) Implements reactor.core.Fuseable.QueueSubscription.requestFusion. Doc from reactor.core.Fuseable.QueueSubscription.requestFusion. Request a specific fusion mode from this QueueSubscription. One should request either SYNC, ASYNC or ANY modes (never NONE) and the implementor should return NONE, SYNC or ASYNC (never ANY). For example, if a source supports only ASYNC fusion but the intermediate operator supports only SYNC fuseable sources, the operator may request SYNC fusion and the source can reject it via NONE, thus the operator can return NONE as well to downstream and the fusion doesn't happen. Parameters requestedMode:int the mode requested by the intermediate operator Returns:int the actual fusion mode activated Annotations @Override

requestFusion

back to summary

public int requestFusion(int requestedMode)

Implements reactor.core.Fuseable.QueueSubscription.requestFusion.

Doc from reactor.core.Fuseable.QueueSubscription.requestFusion.

Request a specific fusion mode from this QueueSubscription.

One should request either SYNC, ASYNC or ANY modes (never NONE) and the implementor should return NONE, SYNC or ASYNC (never ANY).

For example, if a source supports only ASYNC fusion but the intermediate operator supports only SYNC fuseable sources, the operator may request SYNC fusion and the source can reject it via NONE, thus the operator can return NONE as well to downstream and the fusion doesn't happen.

Parameters

requestedMode:int: the mode requested by the intermediate operator

Returns:int

the actual fusion mode activated

Annotations

@Override

size back to summary

size	back to summary
public int size() Implements java.util.Collection.size. Doc from java.util.Collection.size. Returns the number of elements in this collection. If this collection contains more than `Integer.MAX_VALUE` elements, returns `Integer.MAX_VALUE`. Returns:int the number of elements in this collection Annotations @Override

public int size()

Implements java.util.Collection.size.

Doc from java.util.Collection.size.

Returns the number of elements in this collection. If this collection contains more than Integer.MAX_VALUE elements, returns Integer.MAX_VALUE.

Returns:int

the number of elements in this collection

Annotations

@Override

pack-priv final Class FluxTapFuseable<T, STATE>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class FluxTapFuseable.TapConditionalFuseableSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class FluxTapFuseable.TapFuseableSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail