Class CombineTimestamp
Represents an operator that converts element-timestamp pairs of an observable sequence into proper timestamped elements.
CombineTimestamp
is used primarily to create a sequence of Timestamped<T> values for downstream operators, when timestamps have been extracted from other sources.
Alternatively, CombineTimestamp
can be used to preserve the value of a timestamp during post-processing operations. In this case, even though the timestamped value may be transformed multiple times, we can keep the original acquisition timestamp in a branch and use the Zip operator followed by CombineTimestamp
to carry the timestamp value forward.
[Combinator]
public class CombineTimestamp
- Inheritance
-
CombineTimestamp
- Inherited Members
Methods
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.