Package rx.internal.operators

Class OperatorOnBackpressureLatest<T>

java.lang.Object

rx.internal.operators.OperatorOnBackpressureLatest<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>

public final class OperatorOnBackpressureLatest<T>
extends Object
implements Observable.Operator<T,T>

An operator which drops all but the last received value in case the downstream doesn't request more.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OperatorOnBackpressureLatest.Holder	Holds a singleton instance initialized on class-loading.
(package private) static final class	OperatorOnBackpressureLatest.LatestEmitter<T>	A terminable producer which emits the latest items on request.
(package private) static final class	OperatorOnBackpressureLatest.LatestSubscriber<T>

Constructor Summary

Constructors

Constructor	Description
OperatorOnBackpressureLatest()

Method Summary

Modifier and Type	Method	Description
Subscriber<? super T>	call(Subscriber<? super T> child)
static <T> OperatorOnBackpressureLatest<T>	instance()	Returns a singleton instance of the OnBackpressureLatest operator since it is stateless.

Methods inherited from class java.lang.Object

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

Constructor Details

OperatorOnBackpressureLatest

public OperatorOnBackpressureLatest()

Method Details

instance

public static <T> OperatorOnBackpressureLatest<T> instance()

Returns a singleton instance of the OnBackpressureLatest operator since it is stateless.

Type Parameters:

T - the value type

Returns:

the single instanceof OperatorOnBackpressureLatest

call

public Subscriber<? super T> call(Subscriber<? super T> child)

Specified by:

call in interface Func1<Subscriber<? super T>,Subscriber<? super T>>