Top Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.observable

public final Class ObservableJoin<TLeft, TRight, TLeftEnd, TRightEnd, R>

extends AbstractObservableWithUpstream<TLeft, R>
Class Inheritance
Imports
java.util.*, java.util.concurrent.atomic.*, io.reactivex.rxjava3.core.ObservableSource, .Observer, io.reactivex.rxjava3.disposables.*, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.*, io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.*, io.reactivex.rxjava3.internal.util.ExceptionHelper, io.reactivex.rxjava3.operators.SpscLinkedArrayQueue, io.reactivex.rxjava3.plugins.RxJavaPlugins

Nested and Inner Type Summary

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

Field Summary

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

pack-priv final ObservableSource<? extends TRight>
other

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

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

Inherited from io.reactivex.rxjava3.internal.operators.observable.AbstractObservableWithUpstream:
source

Constructor Summary

AccessConstructor and Description
public
ObservableJoin(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Observer<? super R> observer)

Inherited from io.reactivex.rxjava3.internal.operators.observable.AbstractObservableWithUpstream:
source

Field Detail

leftEndback to summary
pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd
otherback to summary
pack-priv final ObservableSource<? extends TRight> other
resultSelectorback to summary
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector
rightEndback to summary
pack-priv final Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd

Constructor Detail

ObservableJoinback to summary
public ObservableJoin(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Detail

subscribeActualback to summary
protected void subscribeActual(Observer<? super R> observer)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.observable back to summary

pack-priv final Class ObservableJoin.JoinDisposable<TLeft, TRight, TLeftEnd, TRightEnd, R>

extends AtomicInteger
implements Disposable, JoinSupport
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport, io.reactivex.rxjava3.disposables.Disposable

Field Summary

Modifier and TypeField and Description
pack-priv final AtomicInteger
active

pack-priv volatile boolean
cancelled

pack-priv final CompositeDisposable
disposables

pack-priv final Observer<? super R>
downstream

pack-priv final AtomicReference<Throwable>
error

pack-priv static final Integer
LEFT_CLOSE

pack-priv static final Integer
LEFT_VALUE

pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>>
leftEnd

pack-priv int
leftIndex

pack-priv final Map<Integer, TLeft>
lefts

pack-priv final SpscLinkedArrayQueue<Object>
queue

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 ObservableSource<TRightEnd>>
rightEnd

pack-priv int
rightIndex

pack-priv final Map<Integer, TRight>
rights

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Summary

AccessConstructor and Description
pack-priv
JoinDisposable(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
cancelAll()

public void
dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
pack-priv void
drain()

pack-priv void
errorAll(Observer<?> a)

pack-priv void
fail(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)

public void
innerClose(boolean isLeft, ObservableGroupJoin.LeftRightEndObserver index)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerClose.

public void
innerCloseError(Throwable ex)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerCloseError.

public void
innerComplete(ObservableGroupJoin.LeftRightObserver sender)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerComplete.

public void
innerError(Throwable ex)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerError.

public void
innerValue(boolean isLeft, Object o)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerValue.

public boolean
isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
Inherited from java.util.concurrent.atomic.AtomicInteger:
accumulateAndGetaddAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetdecrementAndGetdoubleValuefloatValuegetgetAcquiregetAndAccumulategetAndAddgetAndDecrementgetAndIncrementgetAndSetgetAndUpdategetOpaquegetPlainincrementAndGetintValuelazySetlongValuesetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

activeback to summary
pack-priv final AtomicInteger active
cancelledback to summary
pack-priv volatile boolean cancelled
disposablesback to summary
pack-priv final CompositeDisposable disposables
downstreamback to summary
pack-priv final Observer<? super R> downstream
errorback to summary
pack-priv final AtomicReference<Throwable> error
LEFT_CLOSEback to summary
pack-priv static final Integer LEFT_CLOSE
LEFT_VALUEback to summary
pack-priv static final Integer LEFT_VALUE
leftEndback to summary
pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd
leftIndexback to summary
pack-priv int leftIndex
leftsback to summary
pack-priv final Map<Integer, TLeft> lefts
queueback to summary
pack-priv final SpscLinkedArrayQueue<Object> queue
resultSelectorback to summary
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector
RIGHT_CLOSEback to summary
pack-priv static final Integer RIGHT_CLOSE
RIGHT_VALUEback to summary
pack-priv static final Integer RIGHT_VALUE
rightEndback to summary
pack-priv final Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd
rightIndexback to summary
pack-priv int rightIndex
rightsback to summary
pack-priv final Map<Integer, TRight> rights
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Detail

JoinDisposableback to summary
pack-priv JoinDisposable(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Detail

cancelAllback to summary
pack-priv void cancelAll()
disposeback to summary
public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
drainback to summary
pack-priv void drain()
errorAllback to summary
pack-priv void errorAll(Observer<?> a)
failback to summary
pack-priv void fail(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)
innerCloseback to summary
public void innerClose(boolean isLeft, ObservableGroupJoin.LeftRightEndObserver index)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerClose.

Annotations
@Override
innerCloseErrorback to summary
public void innerCloseError(Throwable ex)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerCloseError.

Annotations
@Override
innerCompleteback to summary
public void innerComplete(ObservableGroupJoin.LeftRightObserver sender)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerComplete.

Annotations
@Override
innerErrorback to summary
public void innerError(Throwable ex)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerError.

Annotations
@Override
innerValueback to summary
public void innerValue(boolean isLeft, Object o)

Implements io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerValue.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override