Class GroupByTime

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

[Combinator]
[WorkflowElementCategory(ElementCategory.Combinator)]
public class GroupByTime

Inheritance

object ← GroupByTime

Inherited Members

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

Constructors

GroupByTime()

public GroupByTime()

Properties

ChunkSize

public int ChunkSize { get; set; }

Property Value

int

ClosingDuration

public TimeSpan? ClosingDuration { get; set; }

Property Value

TimeSpan?

ClosingDurationXml

[Browsable(false)]
public string ClosingDurationXml { get; set; }

Property Value

string

Methods

Process<TSource>(IObservable<Timestamped<TSource>>)

public IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource>(IObservable<Timestamped<TSource>> source)

Parameters

source IObservable<Timestamped<TSource>>

Returns

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>>

Type Parameters

TSource

Process(IObservable<HarpMessage>)

public IObservable<IGroupedObservable<DateTime, HarpMessage>> Process(IObservable<HarpMessage> source)

Parameters

source IObservable<HarpMessage>

Returns

IObservable<IGroupedObservable<DateTime, HarpMessage>>

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

public IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource>(IObservable<Tuple<TSource, double>> source)

Parameters

source IObservable<Tuple<TSource, double>>

Returns

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>>

Type Parameters

TSource

Process<TSource>(IObservable<Timestamped<TSource>>, IObservable<HarpMessage>)

public IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource>(IObservable<Timestamped<TSource>> source, IObservable<HarpMessage> heartbeats)

Parameters

source IObservable<Timestamped<TSource>>

heartbeats IObservable<HarpMessage>

Returns

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>>

Type Parameters

TSource

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

public IObservable<IGroupedObservable<DateTime, HarpMessage>> Process(IObservable<HarpMessage> source, IObservable<HarpMessage> heartbeats)

Parameters

source IObservable<HarpMessage>

heartbeats IObservable<HarpMessage>

Returns

IObservable<IGroupedObservable<DateTime, HarpMessage>>

Process<TSource>(IObservable<Tuple<TSource, double>>, IObservable<HarpMessage>)

public IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource>(IObservable<Tuple<TSource, double>> source, IObservable<HarpMessage> heartbeats)

Parameters

source IObservable<Tuple<TSource, double>>

heartbeats IObservable<HarpMessage>

Returns

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>>

Type Parameters

TSource