Top Description Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxHandleFuseable<T, R>

extends InternalFluxOperator<T, R>
implements Fuseable
Class Inheritance
All Implemented Interfaces
reactor.core.Fuseable
Type Parameters
<T>
the source value type
<R>
the result value type
Imports
java.util.Objects, java.util.function.BiConsumer, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, .Exceptions, .Fuseable, reactor.util.annotation.Nullable, reactor.util.context.Context, .ContextView
Maps the values of the source publisher one-on-one via a handler function.

This variant allows composing fuseable stages.

See Also
Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FluxHandleFuseable.HandleFuseableConditionalSubscriber<T, R>

pack-priv static class
FluxHandleFuseable.HandleFuseableSubscriber<T, R>

Field Summary

Modifier and TypeField and Description
pack-priv final BiConsumer<? super T, SynchronousSink<R>>
handler

Inherited from reactor.core.publisher.InternalFluxOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
FluxHandleFuseable(Flux<? extends T>
the source Publisher instance
source, BiConsumer<? super T, SynchronousSink<R>>
the handler function
handler)

Constructs a FluxMap instance with the given source and handler.

Method Summary

Modifier and TypeMethod and Description
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 R> 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