Method Process
Process(IObservable<IGroupedObservable<int, HarpMessage>>)
Writes each Harp message in the sequence of observable groups to the corresponding binary file, where the name of each file is generated from the common group register address.
public IObservable<IGroupedObservable<int, HarpMessage>> Process(IObservable<IGroupedObservable<int, HarpMessage>> source)Parameters
sourceIObservable<IGroupedObservable<int, HarpMessage>>A sequence of observable groups, each of which corresponds to a unique register address.
Returns
- IObservable<IGroupedObservable<int, HarpMessage>>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the Harp messages in each group to the corresponding file.
Process(IObservable<IGroupedObservable<Type, HarpMessage>>)
Writes each Harp message in the sequence of observable groups to the corresponding binary file, where the name of each file is generated from the common group register name.
public IObservable<IGroupedObservable<Type, HarpMessage>> Process(IObservable<IGroupedObservable<Type, HarpMessage>> source)Parameters
sourceIObservable<IGroupedObservable<Type, HarpMessage>>A sequence of observable groups, each of which corresponds to a unique register type.
Returns
- IObservable<IGroupedObservable<Type, HarpMessage>>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the Harp messages in each group to the corresponding file.