Top Description Fields Methods
reactor.core.publisher

pack-priv Interface SignalPeek<T>

extends Scannable
Known Direct Implementers
reactor.core.publisher.ParallelDoOnEach.DoOnEachSignalPeek, reactor.core.publisher.FluxPeek, reactor.core.publisher.FluxPeekFuseable, reactor.core.publisher.MonoPeek, reactor.core.publisher.MonoPeekFuseable, reactor.core.publisher.ParallelPeek, reactor.core.publisher.SignalLogger
Type Parameters
<T>
the value type of the sequence
Imports
java.util.function.Consumer, .LongConsumer, org.reactivestreams.Subscriber, .Subscription, reactor.core.Scannable, reactor.util.annotation.Nullable, reactor.util.context.Context
Peek into the lifecycle and sequence signals.

The callbacks are all optional.

Field Summary

Inherited from reactor.core.Scannable:
OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Method Summary

Modifier and TypeMethod and Description
public default Consumer<? super T>

Returns:

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

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

public Runnable

Returns:

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

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

public Runnable

Returns:

A task that will run on Subscription#cancel()
onCancelCall()

A task that will run on Subscription#cancel()

public Runnable

Returns:

A task that will run on Subscriber#onComplete()
onCompleteCall()

A task that will run on Subscriber#onComplete()

public default Consumer<? super Context>

Returns:

A task that will run on Context propagation from upstream to downstream
onCurrentContextCall()

A task that will run on Context read from downstream to upstream

public Consumer<? super Throwable>

Returns:

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

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

public Consumer<? super T>

Returns:

A consumer that will observe Subscriber#onNext(Object)
onNextCall()

A consumer that will observe Subscriber#onNext(Object)

public LongConsumer

Returns:

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

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

public Consumer<? super Subscription>

Returns:

A consumer that will observe Subscriber#onSubscribe(Subscription)
onSubscribeCall()

A consumer that will observe Subscriber#onSubscribe(Subscription)

Inherited from reactor.core.Scannable:
actualsfrominnersisScanAvailablenameparentsscanscanOrDefaultscanUnsafestepNamestepstagstagsDeduplicated

Method Detail

onAfterNextCallback to summary
public default Consumer<? super T> 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
@Nullable
onAfterTerminateCallback to summary
public Runnable 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
@Nullable
onCancelCallback to summary
public Runnable onCancelCall()

A task that will run on Subscription#cancel()

Returns:Runnable

A task that will run on Subscription#cancel()

Annotations
@Nullable
onCompleteCallback to summary
public Runnable onCompleteCall()

A task that will run on Subscriber#onComplete()

Returns:Runnable

A task that will run on Subscriber#onComplete()

Annotations
@Nullable
onCurrentContextCallback to summary
public default Consumer<? super Context> onCurrentContextCall()

A task that will run on Context read from downstream to upstream

Returns:Consumer<? super Context>

A task that will run on Context propagation from upstream to downstream

Annotations
@Nullable
onErrorCallback to summary
public Consumer<? super Throwable> onErrorCall()

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

Returns:Consumer<? super Throwable>

A consumer that will observe Subscriber#onError(Throwable)

Annotations
@Nullable
onNextCallback to summary
public Consumer<? super T> onNextCall()

A consumer that will observe Subscriber#onNext(Object)

Returns:Consumer<? super T>

A consumer that will observe Subscriber#onNext(Object)

Annotations
@Nullable
onRequestCallback to summary
public LongConsumer onRequestCall()

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

Returns:LongConsumer

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

Annotations
@Nullable
onSubscribeCallback to summary
public Consumer<? super Subscription> onSubscribeCall()

A consumer that will observe Subscriber#onSubscribe(Subscription)

Returns:Consumer<? super Subscription>

A consumer that will observe Subscriber#onSubscribe(Subscription)

Annotations
@Nullable