hu.akarnokd.rxjava2.internal.subscriptions

Class FullArbiter<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

org.reactivestreams.Subscription

public final class FullArbiter<T>
extends java.lang.Object
implements org.reactivestreams.Subscription

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

Constructor Summary

Constructors

Constructor and Description
FullArbiter(org.reactivestreams.Subscriber<? super T> actual, Disposable resource, int capacity)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	onComplete(org.reactivestreams.Subscription s)
void	onError(java.lang.Throwable value, org.reactivestreams.Subscription s)
boolean	onNext(T value, org.reactivestreams.Subscription s)
void	request(long n)
boolean	setSubscription(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

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

Constructor Detail

FullArbiter

public FullArbiter(org.reactivestreams.Subscriber<? super T> actual,
                   Disposable resource,
                   int capacity)

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

setSubscription

public boolean setSubscription(org.reactivestreams.Subscription s)

onNext

public boolean onNext(T value,
                      org.reactivestreams.Subscription s)

onError

public void onError(java.lang.Throwable value,
                    org.reactivestreams.Subscription s)

onComplete

public void onComplete(org.reactivestreams.Subscription s)