Package rx.internal.operators

Class OperatorSampleWithTime<T>

java.lang.Object

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

Returns an Observable that emits the results of sampling the items emitted by the source Observable at a specified time interval.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OperatorSampleWithTime.SamplerSubscriber<T>	The source subscriber and sampler.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Scheduler	scheduler
(package private) final long	time
(package private) final TimeUnit	unit

Constructor Summary

Constructors

Constructor	Description
OperatorSampleWithTime(long time, TimeUnit unit, Scheduler scheduler)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

time

final long time

unit

final TimeUnit unit

scheduler

final Scheduler scheduler

Constructor Details

OperatorSampleWithTime

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

Method Details

call

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

Specified by:

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