Top Description Inners Fields Constructors Methods

reactor.core.publisher

pack-priv final Class FluxGroupBy<T, K, V>

Class Inheritance

extends InternalFluxOperator<T, GroupedFlux<K, V>>
implements Fuseable

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

All Implemented Interfaces

reactor.core.Fuseable

Type Parameters

<T>: the source value type
<K>: the key value type
<V>: the group item value type

Imports

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

Groups upstream items into their own Publisher sequence based on a key selector.

See Also: Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxGroupBy.GroupByMain<T, K, V>
pack-priv static class	FluxGroupBy.UnicastGroupedFlux<K, V>

Field Summary

Modifier and Type	Field and Description
pack-priv final Supplier<? extends Queue<V>>	groupQueueSupplier
pack-priv final Function<? super T, ? extends K>	keySelector
pack-priv final Supplier<? extends Queue<GroupedFlux<K, V>>>	mainQueueSupplier
pack-priv final int	prefetch
pack-priv final Function<? super T, ? extends V>	valueSelector

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

Constructor Summary

Access	Constructor and Description
pack-priv	FluxGroupBy(Flux<? extends T> source, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, Supplier<? extends Queue<GroupedFlux<K, V>>> mainQueueSupplier, Supplier<? extends Queue<V>> groupQueueSupplier, int prefetch)

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 GroupedFlux<K, V>> 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