hu.akarnokd.rxjava2.internal.disposables

Class NbpFullArbiter<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.disposables.NbpFullArbiter<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Disposable

public final class NbpFullArbiter<T>
extends java.lang.Object
implements Disposable

Performs full arbitration of Subscriber events with strict drain (i.e., old emissions of another subscriber are dropped).

Constructor Summary

Constructors

Constructor and Description
NbpFullArbiter(NbpObservable.NbpSubscriber<? super T> actual, Disposable resource, int capacity)

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
void	onComplete(Disposable s)
void	onError(java.lang.Throwable value, Disposable s)
boolean	onNext(T value, Disposable s)
boolean	setSubscription(Disposable s)

Methods inherited from class java.lang.Object

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

Constructor Detail

NbpFullArbiter

public NbpFullArbiter(NbpObservable.NbpSubscriber<? super T> actual,
                      Disposable resource,
                      int capacity)

Method Detail

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

setSubscription

public boolean setSubscription(Disposable s)

onNext

public boolean onNext(T value,
                      Disposable s)

onError

public void onError(java.lang.Throwable value,
                    Disposable s)

onComplete

public void onComplete(Disposable s)