Modifier and Type	Class and Description
private class	ParallelDoOnEach.DoOnEachSignalPeek

Modifier and Type	Field and Description
pack-priv final Consumer<Context>	onComplete
pack-priv final BiConsumer<Context, ? super Throwable>	onError
pack-priv final BiConsumer<Context, ? super T>	onNext
pack-priv final ParallelFlux<T>	source

Access	Constructor and Description
pack-priv	ParallelDoOnEach(ParallelFlux<T> source, BiConsumer<Context, ? super T> onNext, BiConsumer<Context, ? super Throwable> onError, Consumer<Context> onComplete)

Modifier and Type	Method and Description
public int	getPrefetch() Overrides reactor.core.publisher.ParallelFlux.getPrefetch. The prefetch configuration of the component
public int	parallelism() Implements abstract reactor.core.publisher.ParallelFlux.parallelism. Returns the number of expected parallel Subscribers.
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 void	subscribe(CoreSubscriber<? super T>[] the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlux subscribers) Implements abstract reactor.core.publisher.ParallelFlux.subscribe. Subscribes an array of Subscribers to this `ParallelFlux` and triggers the execution chain for all 'rails'.

onComplete	back to summary
pack-priv final Consumer<Context> onComplete

onError	back to summary
pack-priv final BiConsumer<Context, ? super Throwable> onError

onNext	back to summary
pack-priv final BiConsumer<Context, ? super T> onNext

source	back to summary
pack-priv final ParallelFlux<T> source

ParallelDoOnEach	back to summary
pack-priv ParallelDoOnEach(ParallelFlux<T> source, BiConsumer<Context, ? super T> onNext, BiConsumer<Context, ? super Throwable> onError, Consumer<Context> onComplete)

Method Detail

getPrefetch	back to summary
public int getPrefetch() Overrides reactor.core.publisher.ParallelFlux.getPrefetch. Doc from reactor.core.publisher.ParallelFlux.getPrefetch. The prefetch configuration of the component Returns:int the prefetch configuration of the component Annotations @Override

getPrefetch

back to summary

public int getPrefetch()

Overrides reactor.core.publisher.ParallelFlux.getPrefetch.

Doc from reactor.core.publisher.ParallelFlux.getPrefetch.

The prefetch configuration of the component

Returns:int

the prefetch configuration of the component

Annotations

@Override

parallelism	back to summary
public int parallelism() Implements abstract reactor.core.publisher.ParallelFlux.parallelism. Doc from reactor.core.publisher.ParallelFlux.parallelism. Returns the number of expected parallel Subscribers. Returns:int the number of expected parallel Subscribers Annotations @Override

parallelism

back to summary

public int parallelism()

Implements abstract reactor.core.publisher.ParallelFlux.parallelism.

Doc from reactor.core.publisher.ParallelFlux.parallelism.

Returns the number of expected parallel Subscribers.

Returns:int

the number of expected parallel Subscribers

Annotations

@Override

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) 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 @Nullable

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

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

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super T>[] subscribers) Implements abstract reactor.core.publisher.ParallelFlux.subscribe. Doc from reactor.core.publisher.ParallelFlux.subscribe. Subscribes an array of Subscribers to this `ParallelFlux` and triggers the execution chain for all 'rails'. Parameters subscribers:CoreSubscriber<? super T>[] the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlux Annotations @Override @SuppressWarnings:unchecked

public void subscribe(CoreSubscriber<? super T>[] subscribers)

Implements abstract reactor.core.publisher.ParallelFlux.subscribe.

Doc from reactor.core.publisher.ParallelFlux.subscribe.

Subscribes an array of Subscribers to this ParallelFlux and triggers the execution chain for all 'rails'.

Parameters

subscribers:CoreSubscriber<? super T>[]: the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlux

Annotations

@Override
@SuppressWarnings:unchecked

reactor.core.publisher back to summary

private Class ParallelDoOnEach.DoOnEachSignalPeek

Class Inheritance

extends Object
implements SignalPeek<T>

java.lang.Object
reactor.core.publisher.ParallelDoOnEach.DoOnEachSignalPeek

All Implemented Interfaces

reactor.core.publisher.SignalPeek, reactor.core.Scannable

Field Summary

Modifier and Type	Field and Description
pack-priv Runnable	onCompleteCall
pack-priv Consumer<? super Throwable>	onErrorCall
pack-priv Consumer<? super T>	onNextCall

Constructor Summary

Access	Constructor and Description
public	DoOnEachSignalPeek(Context ctx)

Method Summary

Modifier and Type	Method and Description
public Runnable	onAfterTerminateCall() Implements reactor.core.publisher.SignalPeek.onAfterTerminateCall. A task will run after termination via `Subscriber#onComplete()` or `Subscriber#onError(Throwable)`
public Runnable	onCancelCall() Implements reactor.core.publisher.SignalPeek.onCancelCall. A task that will run on `Subscription#cancel()`
public Runnable	onCompleteCall() Implements reactor.core.publisher.SignalPeek.onCompleteCall. A task that will run on `Subscriber#onComplete()`
public Consumer<? super Throwable>	onErrorCall() Implements reactor.core.publisher.SignalPeek.onErrorCall. A consumer that will observe `Subscriber#onError(Throwable)`}
public Consumer<? super T>	onNextCall() Implements reactor.core.publisher.SignalPeek.onNextCall. A consumer that will observe `Subscriber#onNext(Object)`
public LongConsumer	onRequestCall() Implements reactor.core.publisher.SignalPeek.onRequestCall. A consumer of long that will observe `Subscription#request(long)`}
public Consumer<? super Subscription>	onSubscribeCall() Implements reactor.core.publisher.SignalPeek.onSubscribeCall. A consumer that will observe `Subscriber#onSubscribe(Subscription)`
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.

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

Field Detail

onCompleteCall	back to summary
pack-priv Runnable onCompleteCall

onErrorCall	back to summary
pack-priv Consumer<? super Throwable> onErrorCall

onNextCall	back to summary
pack-priv Consumer<? super T> onNextCall

Constructor Detail

DoOnEachSignalPeek	back to summary
public DoOnEachSignalPeek(Context ctx)

Method Detail

onAfterTerminateCall back to summary

onAfterTerminateCall	back to summary
public Runnable onAfterTerminateCall() Implements reactor.core.publisher.SignalPeek.onAfterTerminateCall. Doc from reactor.core.publisher.SignalPeek.onAfterTerminateCall. A task will run after termination via `Subscriber#onComplete()` or `Subscriber#onError(Throwable)` Returns:Runnable A task will run after termination via `Subscriber#onComplete()` or `Subscriber#onError(Throwable)` Annotations @Override

public Runnable onAfterTerminateCall()

Implements reactor.core.publisher.SignalPeek.onAfterTerminateCall.

Doc from reactor.core.publisher.SignalPeek.onAfterTerminateCall.

A task will run after termination via Subscriber#onComplete() or Subscriber#onError(Throwable)

Returns:Runnable

A task will run after termination via Subscriber#onComplete() or Subscriber#onError(Throwable)

Annotations

@Override

onCancelCall back to summary

onCancelCall	back to summary
public Runnable onCancelCall() Implements reactor.core.publisher.SignalPeek.onCancelCall. Doc from reactor.core.publisher.SignalPeek.onCancelCall. A task that will run on `Subscription#cancel()` Returns:Runnable A task that will run on `Subscription#cancel()` Annotations @Override

public Runnable onCancelCall()

Implements reactor.core.publisher.SignalPeek.onCancelCall.

Doc from reactor.core.publisher.SignalPeek.onCancelCall.

A task that will run on Subscription#cancel()

Returns:Runnable

A task that will run on Subscription#cancel()

Annotations

@Override

onCompleteCall back to summary

onCompleteCall	back to summary
public Runnable onCompleteCall() Implements reactor.core.publisher.SignalPeek.onCompleteCall. Doc from reactor.core.publisher.SignalPeek.onCompleteCall. A task that will run on `Subscriber#onComplete()` Returns:Runnable A task that will run on `Subscriber#onComplete()` Annotations @Override

public Runnable onCompleteCall()

Implements reactor.core.publisher.SignalPeek.onCompleteCall.

Doc from reactor.core.publisher.SignalPeek.onCompleteCall.

A task that will run on Subscriber#onComplete()

Returns:Runnable

A task that will run on Subscriber#onComplete()

Annotations

@Override

onErrorCall back to summary

onErrorCall	back to summary
public Consumer<? super Throwable> onErrorCall() Implements reactor.core.publisher.SignalPeek.onErrorCall. Doc from reactor.core.publisher.SignalPeek.onErrorCall. A consumer that will observe `Subscriber#onError(Throwable)`} Returns:Consumer<? super Throwable> A consumer that will observe `Subscriber#onError(Throwable)` Annotations @Override

public Consumer<? super Throwable> onErrorCall()

Implements reactor.core.publisher.SignalPeek.onErrorCall.

Doc from reactor.core.publisher.SignalPeek.onErrorCall.

A consumer that will observe Subscriber#onError(Throwable)}

Returns:Consumer<? super Throwable>

A consumer that will observe Subscriber#onError(Throwable)

Annotations

@Override

onNextCall back to summary

onNextCall	back to summary
public Consumer<? super T> onNextCall() Implements reactor.core.publisher.SignalPeek.onNextCall. Doc from reactor.core.publisher.SignalPeek.onNextCall. A consumer that will observe `Subscriber#onNext(Object)` Returns:Consumer<? super T> A consumer that will observe `Subscriber#onNext(Object)` Annotations @Override

public Consumer<? super T> onNextCall()

Implements reactor.core.publisher.SignalPeek.onNextCall.

Doc from reactor.core.publisher.SignalPeek.onNextCall.

A consumer that will observe Subscriber#onNext(Object)

Returns:Consumer<? super T>

A consumer that will observe Subscriber#onNext(Object)

Annotations

@Override

onRequestCall back to summary

onRequestCall	back to summary
public LongConsumer onRequestCall() Implements reactor.core.publisher.SignalPeek.onRequestCall. Doc from reactor.core.publisher.SignalPeek.onRequestCall. A consumer of long that will observe `Subscription#request(long)`} Returns:LongConsumer A consumer of long that will observe `Subscription#request(long)`} Annotations @Override

public LongConsumer onRequestCall()

Implements reactor.core.publisher.SignalPeek.onRequestCall.

Doc from reactor.core.publisher.SignalPeek.onRequestCall.

A consumer of long that will observe Subscription#request(long)}

Returns:LongConsumer

A consumer of long that will observe Subscription#request(long)}

Annotations

@Override

onSubscribeCall back to summary

onSubscribeCall	back to summary
public Consumer<? super Subscription> onSubscribeCall() Implements reactor.core.publisher.SignalPeek.onSubscribeCall. Doc from reactor.core.publisher.SignalPeek.onSubscribeCall. A consumer that will observe `Subscriber#onSubscribe(Subscription)` Returns:Consumer<? super Subscription> A consumer that will observe `Subscriber#onSubscribe(Subscription)` Annotations @Override

public Consumer<? super Subscription> onSubscribeCall()

Implements reactor.core.publisher.SignalPeek.onSubscribeCall.

Doc from reactor.core.publisher.SignalPeek.onSubscribeCall.

A consumer that will observe Subscriber#onSubscribe(Subscription)

Returns:Consumer<? super Subscription>

A consumer that will observe Subscriber#onSubscribe(Subscription)

Annotations

@Override

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) 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)

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

pack-priv final Class ParallelDoOnEach<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ParallelDoOnEach.DoOnEachSignalPeek

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail