Package rx.internal.operators

Class OperatorTimestamp<T>

java.lang.Object

rx.internal.operators.OperatorTimestamp<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

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

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

Wraps each item emitted by a source Observable in a Timestamped object.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
OperatorTimestamp(Scheduler scheduler)

Method Summary

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

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

OperatorTimestamp

public OperatorTimestamp(Scheduler scheduler)

Method Details

call

public Subscriber<? super T> call(Subscriber<? super Timestamped<T>> o)

Specified by:

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

Returns:

a sequence of timestamped values created by adding timestamps to each item in the input sequence.