Top Description Fields Constructors Methods
reactor.core.publisher

pack-priv final Class MonoPeekFuseable<T>

extends InternalMonoOperator<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.CoreSubscriber, .Fuseable, reactor.util.annotation.Nullable
Peeks out values that make a filter function return false.
See Also
Reactive-Streams-Commons

Field Summary

Modifier and TypeField and Description
pack-priv final Runnable
onCancelCall

pack-priv final Consumer<? super T>
onNextCall

pack-priv final LongConsumer
onRequestCall

pack-priv final Consumer<? super Subscription>
onSubscribeCall

Inherited from reactor.core.publisher.InternalMonoOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
MonoPeekFuseable(Mono<? extends T> source, Consumer<? super Subscription> onSubscribeCall, Consumer<? super T> onNextCall, 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.InternalMonoOperator.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.InternalMonoOperator.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.InternalMonoOperator:
nextOptimizableSourcesourcesubscribe

Field Detail

onCancelCallback to summary
pack-priv final Runnable onCancelCall
onNextCallback to summary
pack-priv final Consumer<? super T> onNextCall
onRequestCallback to summary
pack-priv final LongConsumer onRequestCall
onSubscribeCallback to summary
pack-priv final Consumer<? super Subscription> onSubscribeCall

Constructor Detail

MonoPeekFuseableback to summary
pack-priv MonoPeekFuseable(Mono<? extends T> source, Consumer<? super Subscription> onSubscribeCall, Consumer<? super T> onNextCall, LongConsumer onRequestCall, Runnable onCancelCall)

Method Detail

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

Overrides reactor.core.publisher.InternalMonoOperator.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
subscribeOrReturnback to summary
public CoreSubscriber<? super T> subscribeOrReturn(CoreSubscriber<? super T> actual)

Implements abstract reactor.core.publisher.InternalMonoOperator.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
@SuppressWarnings:unchecked