Class ObservableJoin.JoinDisposable<TLeft,TRight,TLeftEnd,TRightEnd,R>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.observable.ObservableJoin.JoinDisposable<TLeft,TRight,TLeftEnd,TRightEnd,R>
- All Implemented Interfaces:
Disposable
,ObservableGroupJoin.JoinSupport
,Serializable
static final class ObservableJoin.JoinDisposable<TLeft,TRight,TLeftEnd,TRightEnd,R>
extends AtomicInteger
implements Disposable, ObservableGroupJoin.JoinSupport
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final AtomicInteger
(package private) boolean
(package private) final CompositeDisposable
(package private) final AtomicReference
<Throwable> (package private) static final Integer
(package private) static final Integer
(package private) final Function
<? super TLeft, ? extends ObservableSource<TLeftEnd>> (package private) int
(package private) final SpscLinkedArrayQueue
<Object> (package private) final BiFunction
<? super TLeft, ? super TRight, ? extends R> (package private) static final Integer
(package private) static final Integer
(package private) final Function
<? super TRight, ? extends ObservableSource<TRightEnd>> (package private) int
private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionJoinDisposable
(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 TypeMethodDescription(package private) void
void
dispose()
Dispose the resource, the operation should be idempotent.(package private) void
drain()
(package private) void
(package private) void
fail
(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q) void
innerClose
(boolean isLeft, ObservableGroupJoin.LeftRightEndObserver index) void
void
void
innerError
(Throwable ex) void
innerValue
(boolean isLeft, Object o) boolean
Returns true if this resource has been disposed.Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
Methods inherited from class java.lang.Number
byteValue, shortValue
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
queue
-
disposables
-
lefts
-
rights
-
error
-
leftEnd
-
rightEnd
-
resultSelector
-
active
-
leftIndex
int leftIndex -
rightIndex
int rightIndex -
cancelled
volatile boolean cancelled -
LEFT_VALUE
-
RIGHT_VALUE
-
LEFT_CLOSE
-
RIGHT_CLOSE
-
-
Constructor Details
-
JoinDisposable
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 Details
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
cancelAll
void cancelAll() -
errorAll
-
fail
-
drain
void drain() -
innerError
- Specified by:
innerError
in interfaceObservableGroupJoin.JoinSupport
-
innerComplete
- Specified by:
innerComplete
in interfaceObservableGroupJoin.JoinSupport
-
innerValue
- Specified by:
innerValue
in interfaceObservableGroupJoin.JoinSupport
-
innerClose
- Specified by:
innerClose
in interfaceObservableGroupJoin.JoinSupport
-
innerCloseError
- Specified by:
innerCloseError
in interfaceObservableGroupJoin.JoinSupport
-