Class CreateTimestamped
Represents an operator that converts element-timestamp pairs in an observable sequence into System.Reactive.Timestamped<T> values.
CreateTimestamped is used primarily to create a sequence of System.Reactive.Timestamped<T> values for downstream operators, when timestamps have been extracted from other sources. Alternatively, CreateTimestamped can be used to preserve the value of a timestamp during post-processing operations.
Examples
Use CreateTimestamped to carry forward and preserve a timestamp value during post-processing.
[Combinator]
public class CreateTimestamped
- Inheritance
-
CreateTimestamped
- Inherited Members
Methods
- Process<TSource>(IObservable<Tuple<TSource, DateTimeOffset>>)
Converts element-timestamp pairs in an observable sequence into System.Reactive.Timestamped<T> values.