Method Process
Process(IObservable<HarpMessage>)
Groups an observable sequence of Harp.Behavior messages by register type.
public override IObservable<IGroupedObservable<Type, HarpMessage>> Process(IObservable<HarpMessage> source)
Parameters
source
IObservable<HarpMessage>The sequence of Harp device messages.
Returns
- IObservable<IGroupedObservable<Type, HarpMessage>>
A sequence of observable groups, each of which corresponds to a unique Harp.Behavior register.