Top Description Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxGroupJoin<TLeft, TRight, TLeftEnd, TRightEnd, R>

extends InternalFluxOperator<TLeft, R>
Class Inheritance
Type Parameters
<TLeft>
the left Publisher to correlate items from the source Publisher with
<TRight>
the other Publisher to correlate items from the source Publisher with
<TLeftEnd>
type that a function returns via a Publisher whose emissions indicate the duration of the values of the source Publisher
<TRightEnd>
type that a function that returns via a Publisher whose emissions indicate the duration of the values of the right Publisher
<R>
type that a function that takes an item emitted by each Publisher and returns the value to be emitted by the resulting Publisher
Imports
java.util.LinkedHashMap, .Map, .Objects, .Queue, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.BiFunction, .BiPredicate, .Function, .Supplier, java.util.stream.Stream, org.reactivestreams.Publisher, .Subscriber, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Disposables, .Exceptions, .Scannable, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context
A Publisher that correlates two Publishers when they overlap in time and groups the results.

There are no guarantees in what order the items get combined when multiple items from one or both source Publishers overlap.

Since
3.0
See Also
https://github.com/reactor/reactive-streams-commons

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FluxGroupJoin.GroupJoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>

pack-priv static interface
FluxGroupJoin.JoinSupport<T>

pack-priv static class
FluxGroupJoin.LeftRightEndSubscriber

pack-priv static class
FluxGroupJoin.LeftRightSubscriber

Field Summary

Modifier and TypeField and Description
pack-priv final Function<? super TLeft, ? extends Publisher<TLeftEnd>>
leftEnd

pack-priv final Publisher<? extends TRight>
other

pack-priv final Supplier<? extends Queue<TRight>>
processorQueueSupplier

pack-priv final BiFunction<? super TLeft, ? super Flux<TRight>, ? extends R>
resultSelector

pack-priv final Function<? super TRight, ? extends Publisher<TRightEnd>>
rightEnd

Inherited from reactor.core.publisher.InternalFluxOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
FluxGroupJoin(Flux<TLeft> source, Publisher<? extends TRight> other, Function<? super TLeft, ? extends Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Flux<TRight>, ? extends R> resultSelector, Supplier<? extends Queue<Object>> queueSupplier, Supplier<? extends Queue<TRight>> processorQueueSupplier)

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 TLeft>
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