Class TimestampOperator
Extension methods implementing the timestamp operator.
public static class TimestampOperator
- Inheritance
-
System.ObjectTimestampOperator
Methods
Timestamp<T>(Observable<T>, IScheduler?)
Tags each value emitted by source with the time it was received, using
scheduler's notion of "now". Errors and completion are passed through unchanged.
public static Observable<Timestamp<T>> Timestamp<T>(this Observable<T> source, IScheduler? scheduler = null)
Parameters
sourceObservable<T>The source sequence.
schedulerISchedulerThe scheduler whose Now is used to time each emission; defaults to Instance when null.
Returns
- Observable<Timestamp<T>>
An observable of Timestamp<T> values pairing each source value with the time it was received.
Type Parameters
TThe type of values emitted by
source.