Method Process
Process(IObservable<byte[]>)
Converts an observable sequence of byte arrays into a sequence of Harp messages. Each array of bytes should contain the full binary representation of a Harp message.
public override IObservable<HarpMessage> Process(IObservable<byte[]> source)
Parameters
source
IObservable<byte[]>An observable sequence of byte arrays.
Returns
- IObservable<HarpMessage>
An observable sequence of Harp messages.