Class MetadataSource<TMetadata>

Namespace: Aeon.Acquisition
Assembly: Aeon.Acquisition.dll

[Combinator]
[WorkflowElementCategory(ElementCategory.Source)]
public abstract class MetadataSource<TMetadata>

Type Parameters

TMetadata

Inheritance

object ← MetadataSource<TMetadata>

Inherited Members

object.ToString(), object.Equals(object), object.Equals(object, object), object.ReferenceEquals(object, object), object.GetHashCode(), object.GetType(), object.MemberwiseClone()

Methods

OnNext(TMetadata)

public void OnNext(TMetadata value)

Parameters

value TMetadata

Process()

public virtual IObservable<TMetadata> Process()

Returns

IObservable<TMetadata>

Process(IObservable<HarpMessage>)

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

Parameters

source IObservable<HarpMessage>

Returns

IObservable<Timestamped<TMetadata>>