Top Description Fields Constructors Methods
rx.internal.operators

public final Class OperatorTimestamp<T>

extends Object
implements Observable.Operator<Timestamped<T>, T>
Class Inheritance
All Implemented Interfaces
rx.Observable.Operator, rx.functions.Func1, rx.functions.Function
Type Parameters
<T>
the value type
Imports
rx.*, .Observable.Operator, rx.schedulers.Timestamped
Wraps each item emitted by a source Observable in a Timestamped object.

Field Summary

Modifier and TypeField and Description
pack-priv final Scheduler
scheduler

Constructor Summary

AccessConstructor and Description
public
OperatorTimestamp(Scheduler scheduler)

Method Summary

Modifier and TypeMethod and Description
public Subscriber<? super T>

Returns:

a sequence of timestamped values created by adding timestamps to each item in the input sequence.
call(final Subscriber<? super Timestamped<T>> o)

Implements rx.functions.Func1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

schedulerback to summary
pack-priv final Scheduler scheduler

Constructor Detail

OperatorTimestampback to summary
public OperatorTimestamp(Scheduler scheduler)

Method Detail

callback to summary
public Subscriber<? super T> call(final Subscriber<? super Timestamped<T>> o)

Implements rx.functions.Func1.call.

Returns:Subscriber<? super T>

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

Annotations
@Override