Top Description Inners Fields Constructors Methods

reactor.core.publisher

pack-priv final Class FluxPublishMulticast<T, R>

Class Inheritance

extends InternalFluxOperator<T, R>
implements Fuseable

java.lang.Object
reactor.core.publisher.Flux
reactor.core.publisher.FluxOperator
reactor.core.publisher.InternalFluxOperator
reactor.core.publisher.FluxPublishMulticast

All Implemented Interfaces

reactor.core.Fuseable

Type Parameters

<T>: the source value type
<R>: the output value type

Imports

java.util.Objects, .Queue, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.Function, .Supplier, java.util.stream.Stream, org.reactivestreams.Publisher, .Subscription, reactor.core.CoreSubscriber, .Exceptions, .Fuseable, .Scannable, reactor.util.annotation.Nullable, reactor.util.context.Context

Shares a sequence for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.

See Also: Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxPublishMulticast.CancelFuseableMulticaster<T>
pack-priv static class	FluxPublishMulticast.CancelMulticaster<T>
pack-priv static class	FluxPublishMulticast.FluxPublishMulticaster<T>
pack-priv static interface	FluxPublishMulticast.PublishMulticasterParent
pack-priv static class	FluxPublishMulticast.PublishMulticastInner<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final int	prefetch
pack-priv final Supplier<? extends Queue<T>>	queueSupplier
pack-priv final Function<? super Flux<T>, ? extends Publisher<? extends R>>	transform

Inherited from reactor.core.publisher.InternalFluxOperator:: optimizableOperator

Constructor Summary

Access	Constructor and Description
pack-priv	FluxPublishMulticast(Flux<? extends T> source, Function<? super Flux<T>, ? extends Publisher<? extends R>> transform, int prefetch, Supplier<? extends Queue<T>> queueSupplier)

Method Summary

Modifier and Type	Method and Description
public int	getPrefetch() Overrides reactor.core.publisher.Flux.getPrefetch. The prefetch configuration of the `Flux`
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:: nextOptimizableSource source subscribe