Class CreateTimestamped

Namespace

Bonsai.Harp

Assembly

Bonsai.Harp.dll

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

object

CreateTimestamped

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

Methods

Process(IObservable<HarpMessage>)

Creates an observable sequence of timestamped message values surfacing the timestamp of the message object in fractional seconds.

public IObservable<Timestamped<HarpMessage>> Process(IObservable<HarpMessage> source)

Parameters

source IObservable<HarpMessage>

A sequence of timestamped HarpMessage objects.

Returns

IObservable<Timestamped<HarpMessage>>

An observable sequence of timestamped values representing the original message and its timestamp, 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.

public IObservable<Timestamped<T>> Process<T>(IObservable<Timestamped<T>> source)

Parameters

source IObservable<Timestamped<T>>

A sequence of Timestamped<T> values specifying the timestamp in a local scheduler clock.

Returns

IObservable<Timestamped<T>>

An observable sequence of Harp timestamped payload values.

Type Parameters

T

The type of the value in the timestamped payload.

Process<T>(IObservable<Tuple<T, HarpMessage>>)

Creates an observable sequence of timestamped payload values from a sequence of value-message pairs.

public IObservable<Timestamped<T>> Process<T>(IObservable<Tuple<T, HarpMessage>> source)

Parameters

source IObservable<Tuple<T, HarpMessage>>

A sequence of value-message pairs, where the second element is a HarpMessage specifying the timestamp of the payload, in fractional seconds.

Returns

IObservable<Timestamped<T>>

An observable sequence of timestamped payload values.

Type Parameters

T

The type of the value in the timestamped payload.

Process<T>(IObservable<Tuple<T, double>>)

Creates an observable sequence of timestamped payload values from a sequence of value-timestamp pairs.

public IObservable<Timestamped<T>> Process<T>(IObservable<Tuple<T, double>> source)

Parameters

source IObservable<Tuple<T, double>>

A sequence of value-timestamp pairs, where the second element specifies the timestamp of the payload, in fractional seconds.

Returns

IObservable<Timestamped<T>>

An observable sequence of timestamped payload values.

Type Parameters

T

The type of the value in the timestamped payload.