Package rx.internal.operators

Class OperatorTakeLastTimed<T>

java.lang.Object

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

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final long	ageMillis
(package private) final int	count
(package private) final Scheduler	scheduler

Constructor Summary

Constructors

Constructor	Description
OperatorTakeLastTimed(int count, long time, TimeUnit unit, Scheduler scheduler)
OperatorTakeLastTimed(long time, TimeUnit unit, Scheduler scheduler)

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

ageMillis

final long ageMillis

scheduler

final Scheduler scheduler

count

final int count

Constructor Details

OperatorTakeLastTimed

public OperatorTakeLastTimed(long time,
 TimeUnit unit,
 Scheduler scheduler)

OperatorTakeLastTimed

public OperatorTakeLastTimed(int count,
 long time,
 TimeUnit unit,
 Scheduler scheduler)

Method Details

call

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

Specified by:

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