Method Process
Process(IObservable<HarpMessage>)
Writes each Harp message in the sequence to the specified binary file, and the contents of the device metadata file to a separate text file.
public override IObservable<HarpMessage> Process(IObservable<HarpMessage> source)Parameters
sourceIObservable<HarpMessage>The sequence of messages to write to the file.
Returns
- IObservable<HarpMessage>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the messages to a raw binary file, and the contents of the device metadata file to a separate text file.
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. The contents of the device metadata file are written to a separate text file.
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, and the contents of the device metadata file to a separate text 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. The contents of the device metadata file are written to a separate text file.
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, and the contents of the device metadata file to a separate text file.