Class CreateTimestamped
Represents an operator that creates a sequence of timestamped payload values from a sequence of value-timestamp pairs.
[Combinator]
[WorkflowElementCategory(ElementCategory.Transform)]
public sealed class CreateTimestamped
- Inheritance
-
CreateTimestamped
- Inherited Members
Methods
- Process(IObservable<HarpMessage>)
Creates an observable sequence of timestamped message values surfacing the timestamp of the message object in fractional seconds.
- Process<T>(IObservable<Timestamped<T>>)
Creates an observable sequence of timestamped message values by converting the timestamp in the local scheduler clock to a Harp timestamp, in fractional seconds relative to the reference time.
- Process<T>(IObservable<Tuple<T, HarpMessage>>)
Creates an observable sequence of timestamped payload values from a sequence of value-message pairs.
- Process<T>(IObservable<Tuple<T, double>>)
Creates an observable sequence of timestamped payload values from a sequence of value-timestamp pairs.