Package rx.internal.operators

Class OperatorTimeInterval<T>

java.lang.Object

rx.internal.operators.OperatorTimeInterval<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

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

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

Records the time interval between consecutive elements in an observable sequence.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Scheduler	scheduler

Constructor Summary

Constructors

Constructor	Description
OperatorTimeInterval(Scheduler scheduler)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

scheduler

final Scheduler scheduler

Constructor Details

OperatorTimeInterval

public OperatorTimeInterval(Scheduler scheduler)

Method Details

call

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

Specified by:

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