Class MaybeEqualSingle.EqualCoordinator<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.operators.maybe.MaybeEqualSingle.EqualCoordinator<T>

All Implemented Interfaces:

Disposable, Serializable

Enclosing class:

MaybeEqualSingle<T>

static final class MaybeEqualSingle.EqualCoordinator<T>
extends AtomicInteger
implements Disposable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final SingleObserver<? super Boolean>	downstream
(package private) final BiPredicate<? super T, ? super T>	isEqual
(package private) final MaybeEqualSingle.EqualObserver<T>	observer1
(package private) final MaybeEqualSingle.EqualObserver<T>	observer2

Constructor Summary

Constructors

Constructor	Description
EqualCoordinator(SingleObserver<? super Boolean> actual, BiPredicate<? super T, ? super T> isEqual)

Method Summary

Modifier and Type	Method	Description
void	dispose()	Dispose the resource, the operation should be idempotent.
(package private) void	done()
(package private) void	error(MaybeEqualSingle.EqualObserver<T> sender, Throwable ex)
boolean	isDisposed()	Returns true if this resource has been disposed.
(package private) void	subscribe(MaybeSource<? extends T> source1, MaybeSource<? extends T> source2)

Methods inherited from class 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 Number

byteValue, shortValue

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

downstream

final SingleObserver<? super Boolean> downstream

observer1

final MaybeEqualSingle.EqualObserver<T> observer1

observer2

final MaybeEqualSingle.EqualObserver<T> observer2

isEqual

final BiPredicate<? super T, ? super T> isEqual

Constructor Details

EqualCoordinator

EqualCoordinator(SingleObserver<? super Boolean> actual,
 BiPredicate<? super T, ? super T> isEqual)

Method Details

subscribe

void subscribe(MaybeSource<? extends T> source1,
 MaybeSource<? extends T> source2)

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

isDisposed

public boolean isDisposed()

Description copied from interface: Disposable

Returns true if this resource has been disposed.

Specified by:

isDisposed in interface Disposable

Returns:

true if this resource has been disposed

done

void done()

error

void error(MaybeEqualSingle.EqualObserver<T> sender,
 Throwable ex)