Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxDoOnEach.DoOnEachConditionalSubscriber<T>
pack-priv static class	FluxDoOnEach.DoOnEachFuseableConditionalSubscriber<T>
pack-priv static class	FluxDoOnEach.DoOnEachFuseableSubscriber<T>
pack-priv static class	FluxDoOnEach.DoOnEachSubscriber<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final Consumer<? super Signal<T>>	onSignal

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

Constructor Summary

Access	Constructor and Description
pack-priv	FluxDoOnEach(Flux<? extends T> source, Consumer<? super Signal<T>> onSignal)

Method Summary

Modifier and Type	Method and Description
pack-priv static <T> FluxDoOnEach.DoOnEachSubscriber<T>	createSubscriber(CoreSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean fuseable, boolean isMono)
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.

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

Field Detail

onSignal	back to summary
pack-priv final Consumer<? super Signal<T>> onSignal

Constructor Detail

FluxDoOnEach	back to summary
pack-priv FluxDoOnEach(Flux<? extends T> source, Consumer<? super Signal<T>> onSignal)

Method Detail

createSubscriber	back to summary
pack-priv static <T> FluxDoOnEach.DoOnEachSubscriber<T> createSubscriber(CoreSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean fuseable, boolean isMono) Annotations @SuppressWarnings:unchecked

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

subscribeOrReturn back to summary

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

reactor.core.publisher back to summary

pack-priv final Class FluxDoOnEach.DoOnEachConditionalSubscriber<T>

Class Inheritance

extends FluxDoOnEach.DoOnEachSubscriber<T>
implements Fuseable.ConditionalSubscriber<T>

java.lang.Object
reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber
reactor.core.publisher.FluxDoOnEach.DoOnEachConditionalSubscriber

All Implemented Interfaces

reactor.core.Fuseable.ConditionalSubscriber, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Inherited from reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber:: actual cachedContext onSignal qs s state STATE_DONE STATE_FLUX_START STATE_MONO_START STATE_SKIP_HANDLER t

Constructor Summary

Access	Constructor and Description
pack-priv	DoOnEachConditionalSubscriber(Fuseable.ConditionalSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean isMono)

Method Summary

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.

Inherited from reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber:: actual cancel currentContext get getContextView getSubscription getThrowable getType onComplete onError onNext onSubscribe request scanUnsafe toString

Constructor Detail

DoOnEachConditionalSubscriber	back to summary
pack-priv DoOnEachConditionalSubscriber(Fuseable.ConditionalSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean isMono)

Method Detail

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 @SuppressWarnings:unchecked

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
@SuppressWarnings:unchecked

reactor.core.publisher back to summary

pack-priv final Class FluxDoOnEach.DoOnEachFuseableConditionalSubscriber<T>

Class Inheritance

extends FluxDoOnEach.DoOnEachFuseableSubscriber<T>
implements Fuseable.ConditionalSubscriber<T>

java.lang.Object
reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber
reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableSubscriber
reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableConditionalSubscriber

All Implemented Interfaces

reactor.core.Fuseable.ConditionalSubscriber, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Inherited from reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableSubscriber:: fusionMode

Constructor Summary

Access	Constructor and Description
pack-priv	DoOnEachFuseableConditionalSubscriber(Fuseable.ConditionalSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean isMono)

Method Summary

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.

Inherited from reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableSubscriber:: clear isEmpty onNext poll requestFusion size

Constructor Detail

DoOnEachFuseableConditionalSubscriber	back to summary
pack-priv DoOnEachFuseableConditionalSubscriber(Fuseable.ConditionalSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean isMono)

Method Detail

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 @SuppressWarnings:unchecked

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
@SuppressWarnings:unchecked

reactor.core.publisher back to summary

pack-priv Class FluxDoOnEach.DoOnEachFuseableSubscriber<T>

Class Inheritance

extends FluxDoOnEach.DoOnEachSubscriber<T>
implements Fuseable, Fuseable.QueueSubscription<T>

java.lang.Object
reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber
reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableSubscriber

All Implemented Interfaces

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

Known Direct Subclasses

reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableConditionalSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv int	fusionMode

Inherited from reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber:: actual cachedContext onSignal qs s state STATE_DONE STATE_FLUX_START STATE_MONO_START STATE_SKIP_HANDLER t

Constructor Summary

Access	Constructor and Description
pack-priv	DoOnEachFuseableSubscriber(CoreSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean isMono)

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).
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.FluxDoOnEach.DoOnEachSubscriber.onNext. Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `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 mode) 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.FluxDoOnEach.DoOnEachSubscriber:: actual cancel currentContext get getContextView getSubscription getThrowable getType onComplete onError onSubscribe request scanUnsafe toString

Field Detail

fusionMode	back to summary
pack-priv int fusionMode

Constructor Detail

DoOnEachFuseableSubscriber	back to summary
pack-priv DoOnEachFuseableSubscriber(CoreSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean isMono)

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

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.FluxDoOnEach.DoOnEachSubscriber.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 @Override

public void onNext(T t)

Overrides reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber.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

@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 mode) 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 mode: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 mode)

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

mode: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

reactor.core.publisher back to summary

pack-priv Class FluxDoOnEach.DoOnEachSubscriber<T>

Class Inheritance

extends Object
implements InnerOperator<T, T>, Signal<T>

java.lang.Object
reactor.core.publisher.FluxDoOnEach.DoOnEachSubscriber

All Implemented Interfaces

reactor.core.publisher.Signal, java.util.function.Consumer, java.util.function.Supplier, reactor.core.publisher.InnerOperator, reactor.core.publisher.InnerProducer, org.reactivestreams.Subscription, reactor.core.Scannable, reactor.core.publisher.InnerConsumer, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Known Direct Subclasses

reactor.core.publisher.FluxDoOnEach.DoOnEachFuseableSubscriber, reactor.core.publisher.FluxDoOnEach.DoOnEachConditionalSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final CoreSubscriber<? super T>	actual
pack-priv final Context	cachedContext
pack-priv final Consumer<? super Signal<T>>	onSignal
pack-priv Fuseable.QueueSubscription<T>	qs
pack-priv Subscription	s
pack-priv short	state
pack-priv static final short	STATE_DONE
pack-priv static final short	STATE_FLUX_START
pack-priv static final short	STATE_MONO_START
pack-priv static final short	STATE_SKIP_HANDLER
pack-priv T	t

Constructor Summary

Access	Constructor and Description
pack-priv	DoOnEachSubscriber(CoreSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean monoFlavor)

Method Summary

Modifier and Type	Method and Description
public CoreSubscriber<? super T>	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 Context	currentContext() Overrides default reactor.core.publisher.InnerOperator.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`.
public T	get() Implements reactor.core.publisher.Signal.get. Retrieves the item associated with this (onNext) signal.
public ContextView	getContextView() Implements reactor.core.publisher.Signal.getContextView. Return the readonly `ContextView` that is accessible by the time this `Signal` was emitted.
public Subscription	getSubscription() Implements reactor.core.publisher.Signal.getSubscription. Read the subscription associated with this (onSubscribe) signal.
public Throwable	getThrowable() Implements reactor.core.publisher.Signal.getThrowable. Read the error associated with this (onError) signal.
public SignalType	getType() Implements reactor.core.publisher.Signal.getType. Read the type of this signal: `SignalType#ON_SUBSCRIBE`, `SignalType#ON_NEXT`, `SignalType#ON_ERROR`, or `SignalType#ON_COMPLETE`
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.
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 T> actual

cachedContext	back to summary
pack-priv final Context cachedContext

onSignal	back to summary
pack-priv final Consumer<? super Signal<T>> onSignal

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

s	back to summary
pack-priv Subscription s

state	back to summary
pack-priv short state

STATE_DONE	back to summary
pack-priv static final short STATE_DONE

STATE_FLUX_START	back to summary
pack-priv static final short STATE_FLUX_START

STATE_MONO_START	back to summary
pack-priv static final short STATE_MONO_START

STATE_SKIP_HANDLER	back to summary
pack-priv static final short STATE_SKIP_HANDLER

t	back to summary
pack-priv T t

Constructor Detail

DoOnEachSubscriber	back to summary
pack-priv DoOnEachSubscriber(CoreSubscriber<? super T> actual, Consumer<? super Signal<T>> onSignal, boolean monoFlavor)

Method Detail

actual	back to summary
public CoreSubscriber<? super T> actual() Implements reactor.core.publisher.InnerProducer.actual. Annotations @Override

actual

back to summary

public CoreSubscriber<? super T> actual()

Implements reactor.core.publisher.InnerProducer.actual.

Annotations

@Override

cancel back to summary

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

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

currentContext back to summary

currentContext	back to summary
public Context currentContext() Overrides default reactor.core.publisher.InnerOperator.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.publisher.InnerOperator.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

get	back to summary
public T get() Implements reactor.core.publisher.Signal.get. Doc from reactor.core.publisher.Signal.get. Retrieves the item associated with this (onNext) signal. Returns:T the item associated with this (onNext) signal, or null if not relevant Annotations @Nullable @Override

get

back to summary

public T get()

Implements reactor.core.publisher.Signal.get.

Doc from reactor.core.publisher.Signal.get.

Retrieves the item associated with this (onNext) signal.

Returns:T

the item associated with this (onNext) signal, or null if not relevant

Annotations

@Nullable
@Override

getContextView back to summary

getContextView	back to summary
public ContextView getContextView() Implements reactor.core.publisher.Signal.getContextView. Doc from reactor.core.publisher.Signal.getContextView. Return the readonly `ContextView` that is accessible by the time this `Signal` was emitted. Returns:ContextView a readonly `ContextView`, or an empty one if no context is available. Annotations @Override

public ContextView getContextView()

Implements reactor.core.publisher.Signal.getContextView.

Doc from reactor.core.publisher.Signal.getContextView.

Return the readonly ContextView that is accessible by the time this Signal was emitted.

Returns:ContextView

a readonly ContextView, or an empty one if no context is available.

Annotations

@Override

getSubscription	back to summary
public Subscription getSubscription() Implements reactor.core.publisher.Signal.getSubscription. Doc from reactor.core.publisher.Signal.getSubscription. Read the subscription associated with this (onSubscribe) signal. Returns:Subscription the Subscription associated with this (onSubscribe) signal, or null if not relevant Annotations @Nullable @Override

getSubscription

back to summary

public Subscription getSubscription()

Implements reactor.core.publisher.Signal.getSubscription.

Doc from reactor.core.publisher.Signal.getSubscription.

Read the subscription associated with this (onSubscribe) signal.

Returns:Subscription

the Subscription associated with this (onSubscribe) signal, or null if not relevant

Annotations

@Nullable
@Override

getThrowable	back to summary
public Throwable getThrowable() Implements reactor.core.publisher.Signal.getThrowable. Doc from reactor.core.publisher.Signal.getThrowable. Read the error associated with this (onError) signal. Returns:Throwable the Throwable associated with this (onError) signal, or null if not relevant Annotations @Nullable @Override

getThrowable

back to summary

public Throwable getThrowable()

Implements reactor.core.publisher.Signal.getThrowable.

Doc from reactor.core.publisher.Signal.getThrowable.

Read the error associated with this (onError) signal.

Returns:Throwable

the Throwable associated with this (onError) signal, or null if not relevant

Annotations

@Nullable
@Override

getType back to summary

public SignalType getType()

Implements reactor.core.publisher.Signal.getType.

Doc from reactor.core.publisher.Signal.getType.

Read the type of this signal: SignalType#ON_SUBSCRIBE, SignalType#ON_NEXT, SignalType#ON_ERROR, or SignalType#ON_COMPLETE

Returns:SignalType

the type of the signal

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.

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

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

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

pack-priv final Class FluxDoOnEach<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class FluxDoOnEach.DoOnEachConditionalSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class FluxDoOnEach.DoOnEachFuseableConditionalSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv Class FluxDoOnEach.DoOnEachFuseableSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class FluxDoOnEach.DoOnEachSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail