Top Description Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxPeekFuseable<T>

extends InternalFluxOperator<T, T>
implements Fuseable, SignalPeek<T>
Class Inheritance
All Implemented Interfaces
reactor.core.publisher.SignalPeek, reactor.core.Scannable, reactor.core.Fuseable
Type Parameters
<T>
the value type
Imports
java.util.function.Consumer, .LongConsumer, org.reactivestreams.Subscription, reactor.core.CorePublisher, .CoreSubscriber, .Exceptions, .Fuseable, reactor.util.annotation.Nullable, reactor.util.context.Context
Peek into the lifecycle events and signals of a sequence.

The callbacks are all optional.

Crashes by the lambdas are ignored.

See Also
Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FluxPeekFuseable.PeekConditionalSubscriber<T>

pack-priv static class
FluxPeekFuseable.PeekFuseableConditionalSubscriber<T>

pack-priv static class
FluxPeekFuseable.PeekFuseableSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Runnable
onAfterTerminateCall

pack-priv final Runnable
onCancelCall

pack-priv final Runnable
onCompleteCall

pack-priv final Consumer<? super Throwable>
onErrorCall

pack-priv final Consumer<? super T>
onNextCall

pack-priv final LongConsumer
onRequestCall

pack-priv final Consumer<? super Subscription>
onSubscribeCall

Inherited from reactor.core.publisher.InternalFluxOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
FluxPeekFuseable(Flux<? extends T> source, Consumer<? super Subscription> onSubscribeCall, Consumer<? super T> onNextCall, Consumer<? super Throwable> onErrorCall, Runnable onCompleteCall, Runnable onAfterTerminateCall, LongConsumer onRequestCall, Runnable onCancelCall)

Method Summary

Modifier and TypeMethod 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)

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