Top Description Inners Fields Constructors Methods

reactor.core.publisher

pack-priv final Class FluxDistinct<T, K, C>

Class Inheritance

extends InternalFluxOperator<T, T>

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

Type Parameters

<T>: the source value type
<K>: the key extracted from the source value to be used for duplicate testing
<C>: the backing store type used together with the keys when testing for duplicates with BiPredicate

Imports

java.util.Objects, java.util.function.BiPredicate, .Consumer, .Function, .Supplier, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, .Fuseable, .Fuseable.ConditionalSubscriber, .Fuseable.QueueSubscription, reactor.util.annotation.Nullable, reactor.util.context.Context

For each subscriber, tracks the source values that have been seen and filters out duplicates.

See Also: Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxDistinct.DistinctConditionalSubscriber<T, K, C>
pack-priv static class	FluxDistinct.DistinctFuseableSubscriber<T, K, C>
pack-priv static class	FluxDistinct.DistinctSubscriber<T, K, C>

Field Summary

Modifier and Type	Field and Description
pack-priv final Consumer<C>	cleanupCallback
pack-priv final Supplier<C>	collectionSupplier
pack-priv final BiPredicate<C, K>	distinctPredicate
pack-priv final Function<? super T, ? extends K>	keyExtractor

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

Constructor Summary

Access	Constructor and Description
pack-priv	FluxDistinct(Flux<? extends T> source, Function<? super T, ? extends K> keyExtractor, Supplier<C> collectionSupplier, BiPredicate<C, K> distinctPredicate, Consumer<C> cleanupCallback)

Method Summary

Modifier and Type	Method 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 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:: nextOptimizableSource source subscribe