Modifier and Type	Class and Description
pack-priv static class	FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>

Modifier and Type	Field and Description
pack-priv final Function<? super TLeft, ? extends Publisher<TLeftEnd>>	leftEnd
pack-priv final Publisher<? extends TRight>	other
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R>	resultSelector
pack-priv final Function<? super TRight, ? extends Publisher<TRightEnd>>	rightEnd

Access	Constructor and Description
pack-priv	FluxJoin(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 TRight, ? extends R> resultSelector)

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

leftEnd	back to summary
pack-priv final Function<? super TLeft, ? extends Publisher<TLeftEnd>> leftEnd

other	back to summary
pack-priv final Publisher<? extends TRight> other

resultSelector	back to summary
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector

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

FluxJoin	back to summary
pack-priv FluxJoin(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 TRight, ? extends R> resultSelector)

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Overrides reactor.core.publisher.InternalFluxOperator.scanUnsafe. Implements reactor.core.Scannable.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override

subscribeOrReturn	back to summary
public CoreSubscriber<? super TLeft> subscribeOrReturn(CoreSubscriber<? super R> actual) Implements abstract reactor.core.publisher.InternalFluxOperator.subscribeOrReturn. Implements reactor.core.publisher.OptimizableOperator.subscribeOrReturn. Doc from reactor.core.publisher.OptimizableOperator.subscribeOrReturn. Allow delegation of the subscription by returning a `CoreSubscriber`, or force subscription encapsulation by returning null. This can be used in conjunction with `nextOptimizableSource()` to perform subscription in a loop instead of by recursion. Returns:CoreSubscriber<? super TLeft> next `CoreSubscriber` or "null" if the subscription was already done inside the method Annotations @Override

pack-priv final Class FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>

Class Inheritance

extends Object
implements FluxGroupJoin.JoinSupport<R>

java.lang.Object
reactor.core.publisher.FluxJoin.JoinSubscription

All Implemented Interfaces

reactor.core.publisher.FluxGroupJoin.JoinSupport, reactor.core.publisher.InnerProducer, org.reactivestreams.Subscription, reactor.core.Scannable

Field Summary

Modifier and Type	Field and Description
pack-priv volatile int	active
pack-priv static final AtomicIntegerFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>>	ACTIVE
pack-priv final CoreSubscriber<? super R>	actual
pack-priv final Disposable.Composite	cancellations
pack-priv volatile Throwable	error
pack-priv static final AtomicReferenceFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>, Throwable>	ERROR
pack-priv static final Integer	LEFT_CLOSE
pack-priv static final Integer	LEFT_VALUE
pack-priv final Function<? super TLeft, ? extends Publisher<TLeftEnd>>	leftEnd
pack-priv int	leftIndex
pack-priv final Map<Integer, TLeft>	lefts
pack-priv final Queue<Object>	queue
pack-priv final BiPredicate<Object, Object>	queueBiOffer
pack-priv volatile long	requested
pack-priv static final AtomicLongFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>>	REQUESTED
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R>	resultSelector
pack-priv static final Integer	RIGHT_CLOSE
pack-priv static final Integer	RIGHT_VALUE
pack-priv final Function<? super TRight, ? extends Publisher<TRightEnd>>	rightEnd
pack-priv int	rightIndex
pack-priv final Map<Integer, TRight>	rights
pack-priv volatile int	wip
pack-priv static final AtomicIntegerFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>>	WIP

Constructor Summary

Access	Constructor and Description
pack-priv	JoinSubscription(CoreSubscriber<? super R> actual, Function<? super TLeft, ? extends Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Summary

Modifier and Type	Method and Description
public final CoreSubscriber<? super R>	actual() Implements reactor.core.publisher.InnerProducer.actual.
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
pack-priv void	drain()
pack-priv void	errorAll(Subscriber<?> a)
public void	innerClose(boolean isLeft, FluxGroupJoin.LeftRightEndSubscriber index) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerClose.
public void	innerCloseError(Throwable ex) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerCloseError.
public void	innerComplete(FluxGroupJoin.LeftRightSubscriber sender) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerComplete.
public void	innerError(Throwable ex) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerError.
public Stream<? extends Scannable>	inners() Overrides default reactor.core.Scannable.inners. Return a `Stream` of referenced inners (flatmap, multicast etc)
public void	innerValue(boolean isLeft, Object o) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerValue.
public void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides default reactor.core.publisher.InnerProducer.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

active	back to summary
pack-priv volatile int active

ACTIVE	back to summary
pack-priv static final AtomicIntegerFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>> ACTIVE

actual	back to summary
pack-priv final CoreSubscriber<? super R> actual

cancellations	back to summary
pack-priv final Disposable.Composite cancellations

error	back to summary
pack-priv volatile Throwable error

ERROR	back to summary
pack-priv static final AtomicReferenceFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>, Throwable> ERROR

LEFT_CLOSE	back to summary
pack-priv static final Integer LEFT_CLOSE

LEFT_VALUE	back to summary
pack-priv static final Integer LEFT_VALUE

leftEnd	back to summary
pack-priv final Function<? super TLeft, ? extends Publisher<TLeftEnd>> leftEnd

leftIndex	back to summary
pack-priv int leftIndex

lefts	back to summary
pack-priv final Map<Integer, TLeft> lefts

queue	back to summary
pack-priv final Queue<Object> queue

queueBiOffer	back to summary
pack-priv final BiPredicate<Object, Object> queueBiOffer

requested	back to summary
pack-priv volatile long requested

REQUESTED	back to summary
pack-priv static final AtomicLongFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>> REQUESTED

resultSelector	back to summary
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector

RIGHT_CLOSE	back to summary
pack-priv static final Integer RIGHT_CLOSE

RIGHT_VALUE	back to summary
pack-priv static final Integer RIGHT_VALUE

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

rightIndex	back to summary
pack-priv int rightIndex

rights	back to summary
pack-priv final Map<Integer, TRight> rights

wip	back to summary
pack-priv volatile int wip

WIP	back to summary
pack-priv static final AtomicIntegerFieldUpdater<FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>> WIP

Constructor Detail

JoinSubscription	back to summary
pack-priv JoinSubscription(CoreSubscriber<? super R> actual, Function<? super TLeft, ? extends Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector) Annotations @SuppressWarnings:unchecked

Method Detail

actual	back to summary
public final CoreSubscriber<? super R> actual() Implements reactor.core.publisher.InnerProducer.actual. Annotations @Override

actual

back to summary

public final CoreSubscriber<? super R> actual()

Implements reactor.core.publisher.InnerProducer.actual.

Annotations

@Override

cancel back to summary

cancel	back to summary
public void cancel() Implements org.reactivestreams.Subscription.cancel. Doc from org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources. Data may still be sent to meet previously signalled demand after calling cancel. Annotations @Override

public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

drain	back to summary
pack-priv void drain()

errorAll	back to summary
pack-priv void errorAll(Subscriber<?> a)

innerClose	back to summary
public void innerClose(boolean isLeft, FluxGroupJoin.LeftRightEndSubscriber index) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerClose. Annotations @Override

innerClose

back to summary

public void innerClose(boolean isLeft, FluxGroupJoin.LeftRightEndSubscriber index)

Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerClose.

Annotations

@Override

innerCloseError	back to summary
public void innerCloseError(Throwable ex) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerCloseError. Annotations @Override

innerCloseError

back to summary

public void innerCloseError(Throwable ex)

Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerCloseError.

Annotations

@Override

innerComplete	back to summary
public void innerComplete(FluxGroupJoin.LeftRightSubscriber sender) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerComplete. Annotations @Override

innerComplete

back to summary

public void innerComplete(FluxGroupJoin.LeftRightSubscriber sender)

Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerComplete.

Annotations

@Override

innerError	back to summary
public void innerError(Throwable ex) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerError. Annotations @Override

innerError

back to summary

public void innerError(Throwable ex)

Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerError.

Annotations

@Override

inners back to summary

inners	back to summary
public Stream<? extends Scannable> inners() Overrides default reactor.core.Scannable.inners. Doc from reactor.core.Scannable.inners. Return a `Stream` of referenced inners (flatmap, multicast etc) Returns:Stream<? extends Scannable> a `Stream` of referenced inners (flatmap, multicast etc) Annotations @Override

public Stream<? extends Scannable> inners()

Overrides default reactor.core.Scannable.inners.

Doc from reactor.core.Scannable.inners.

Return a Stream of referenced inners (flatmap, multicast etc)

Returns:Stream<? extends Scannable>

a Stream of referenced inners (flatmap, multicast etc)

Annotations

@Override

innerValue	back to summary
public void innerValue(boolean isLeft, Object o) Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerValue. Annotations @Override

innerValue

back to summary

public void innerValue(boolean isLeft, Object o)

Implements reactor.core.publisher.FluxGroupJoin.JoinSupport.innerValue.

Annotations

@Override

request back to summary

request	back to summary
public void request(long n) Implements org.reactivestreams.Subscription.request. Doc from org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method. It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the `Publisher` as "effectively unbounded". Whatever has been requested can be sent by the `Publisher` so only signal demand for what can be safely handled. A `Publisher` can send less than is requested if the stream ends but then must emit either `Subscriber#onError(Throwable)` or `Subscriber#onComplete()`. Parameters n:long the strictly positive number of elements to requests to the upstream `Publisher` Annotations @Override

public void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Overrides default reactor.core.publisher.InnerProducer.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override @Nullable

public Object scanUnsafe(Scannable.Attr<T> key)

Overrides default reactor.core.publisher.InnerProducer.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

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

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class FluxJoin.JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail