Method Process
Process<TSource>(IObservable<Tuple<TSource, DateTimeOffset>>)
Converts element-timestamp pairs of an observable sequence into proper timestamped elements.
public IObservable<Timestamped<TSource>> Process<TSource>(IObservable<Tuple<TSource, DateTimeOffset>> source)
Parameters
source
IObservable<Tuple<TSource, DateTimeOffset>>The sequence of element-timestamp pairs.
Returns
- IObservable<Timestamped<TSource>>
An observable sequence of timestamped values.
Type Parameters
TSource
The type of the value being timestamped.