Class ConvertFromMessageBytes
Represents a transform operator which converts an observable sequence of byte arrays into a sequence of Harp messages.
public class ConvertFromMessageBytes : Transform<byte[], HarpMessage>
- Inheritance
-
ConvertFromMessageBytes
- Inherited Members
Methods
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.