Class GroupByRegister
Represents an operator that groups a sequence of Harp messages by register address.
public class GroupByRegister : Combinator<HarpMessage, IGroupedObservable<int, HarpMessage>>
- Inheritance
-
GroupByRegister
- Inherited Members
Methods
Process(IObservable<HarpMessage>)
Groups an observable sequence of Harp messages by register address.
public override IObservable<IGroupedObservable<int, HarpMessage>> Process(IObservable<HarpMessage> source)
Parameters
source
IObservable<HarpMessage>The sequence of Harp device messages.
Returns
- IObservable<IGroupedObservable<int, HarpMessage>>
A sequence of observable groups, each of which corresponds to a unique register address.