Top Description Fields Constructors Methods
reactor.core.publisher

pack-priv final Class ParallelPeek<T>

extends ParallelFlux<T>
implements SignalPeek<T>
Class Inheritance
All Implemented Interfaces
reactor.core.publisher.SignalPeek, reactor.core.Scannable
Type Parameters
<T>
the value type
Imports
java.util.function.Consumer, .LongConsumer, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, .Fuseable, reactor.util.annotation.Nullable
Execute a Consumer in each 'rail' for the current element passing through.

Field Summary

Modifier and TypeField and Description
pack-priv final Consumer<? super T>
onAfterNext

pack-priv final Runnable
onAfterTerminated

pack-priv final Runnable
onCancel

pack-priv final Runnable
onComplete

pack-priv final Consumer<? super Throwable>
onError

pack-priv final Consumer<? super T>
onNext

pack-priv final LongConsumer
onRequest

pack-priv final Consumer<? super Subscription>
onSubscribe

pack-priv final ParallelFlux<T>
source

Constructor Summary

AccessConstructor and Description
pack-priv
ParallelPeek(ParallelFlux<T> source, Consumer<? super T> onNext, Consumer<? super T> onAfterNext, Consumer<? super Throwable> onError, Runnable onComplete, Runnable onAfterTerminated, Consumer<? super Subscription> onSubscribe, LongConsumer onRequest, Runnable onCancel)

Method Summary

Modifier and TypeMethod and Description
public int
getPrefetch()

Overrides reactor.core.publisher.ParallelFlux.getPrefetch.

The prefetch configuration of the component
public Consumer<? super T>
onAfterNextCall()

Overrides default reactor.core.publisher.SignalPeek.onAfterNextCall.

A task that will run after (finally) Subscriber#onNext(Object)
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 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'.
Inherited from reactor.core.publisher.ParallelFlux:
ascheckpointcheckpointcheckpointcollectcollectSortedListcollectSortedListconcatMapconcatMapconcatMapconcatMapDelayErrorconcatMapDelayErrorconcatMapDelayErrordoAfterTerminatedoOnCanceldoOnCompletedoOnEachdoOnErrordoOnNextdoOnRequestdoOnSignaldoOnSubscribedoOnTerminatefilterflatMapflatMapflatMapflatMapfromfromfromfromfromgroupshideloglogloglogmapnameonAssemblyorderedorderedreducereducerunOnrunOnsequentialsequentialsortedsortedsortedMergersubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribetagthentoStringtransformtransformGroupsvalidate

Field Detail

onAfterNextback to summary
pack-priv final Consumer<? super T> onAfterNext
onAfterTerminatedback to summary
pack-priv final Runnable onAfterTerminated
onCancelback to summary
pack-priv final Runnable onCancel
onCompleteback to summary
pack-priv final Runnable onComplete
onErrorback to summary
pack-priv final Consumer<? super Throwable> onError
onNextback to summary
pack-priv final Consumer<? super T> onNext
onRequestback to summary
pack-priv final LongConsumer onRequest
onSubscribeback to summary
pack-priv final Consumer<? super Subscription> onSubscribe
sourceback to summary
pack-priv final ParallelFlux<T> source

Constructor Detail

ParallelPeekback to summary
pack-priv ParallelPeek(ParallelFlux<T> source, Consumer<? super T> onNext, Consumer<? super T> onAfterNext, Consumer<? super Throwable> onError, Runnable onComplete, Runnable onAfterTerminated, Consumer<? super Subscription> onSubscribe, LongConsumer onRequest, Runnable onCancel)

Method Detail

getPrefetchback 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
onAfterNextCallback to summary
public Consumer<? super T> onAfterNextCall()

Overrides default reactor.core.publisher.SignalPeek.onAfterNextCall.

Doc from reactor.core.publisher.SignalPeek.onAfterNextCall.

A task that will run after (finally) Subscriber#onNext(Object)

Returns:Consumer<? super T>

A task that will run after (finally) Subscriber#onNext(Object)

Annotations
@Override
@Nullable
onAfterTerminateCallback 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
onCancelCallback 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
@Nullable
onCompleteCallback 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
@Nullable
onErrorCallback 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
@Nullable
onNextCallback 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
@Nullable
onRequestCallback 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
@Nullable
onSubscribeCallback 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
@Nullable
parallelismback 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
scanUnsafeback 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
subscribeback 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