Class SingleZipArray.ZipCoordinator<T,R>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.operators.single.SingleZipArray.ZipCoordinator<T,R>
-
- All Implemented Interfaces:
Disposable
,java.io.Serializable
- Enclosing class:
- SingleZipArray<T,R>
static final class SingleZipArray.ZipCoordinator<T,R> extends java.util.concurrent.atomic.AtomicInteger implements Disposable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) SingleObserver<? super R>
downstream
(package private) SingleZipArray.ZipSingleObserver<T>[]
observers
private static long
serialVersionUID
(package private) java.lang.Object[]
values
(package private) Function<? super java.lang.Object[],? extends R>
zipper
-
Constructor Summary
Constructors Constructor Description ZipCoordinator(SingleObserver<? super R> observer, int n, Function<? super java.lang.Object[],? extends R> zipper)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dispose()
Dispose the resource, the operation should be idempotent.(package private) void
disposeExcept(int index)
(package private) void
innerError(java.lang.Throwable ex, int index)
(package private) void
innerSuccess(T value, int index)
boolean
isDisposed()
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final SingleObserver<? super R> downstream
-
observers
final SingleZipArray.ZipSingleObserver<T>[] observers
-
values
java.lang.Object[] values
-
-
Constructor Detail
-
ZipCoordinator
ZipCoordinator(SingleObserver<? super R> observer, int n, Function<? super java.lang.Object[],? extends R> zipper)
-
-
Method Detail
-
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
-
dispose
public void dispose()
Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
innerSuccess
void innerSuccess(T value, int index)
-
disposeExcept
void disposeExcept(int index)
-
innerError
void innerError(java.lang.Throwable ex, int index)
-
-