Package rx.internal.operators

Class OperatorTakeLast<T>

java.lang.Object

rx.internal.operators.OperatorTakeLast<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 OperatorTakeLast<T>
extends Object
implements Observable.Operator<T,T>

Returns an Observable that emits the at most the last count items emitted by the source Observable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OperatorTakeLast.TakeLastSubscriber<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	count

Constructor Summary

Constructors

Constructor	Description
OperatorTakeLast(int count)

Method Summary

Modifier and Type	Method	Description
Subscriber<? super T>	call(Subscriber<? super T> subscriber)

Methods inherited from class java.lang.Object

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

Field Details

count

final int count

Constructor Details

OperatorTakeLast

public OperatorTakeLast(int count)

Method Details

call

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

Specified by:

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