Method Process
Process(IObservable<NetMQFrame>)
Converts an observable sequence of message frames into a sequence of strings using the default encoding.
public override IObservable<string> Process(IObservable<NetMQFrame> source)
Parameters
source
IObservable<NetMQFrame>A sequence of NetMQ.NetMQFrame objects representing individual message frames.
Returns
- IObservable<string>
A sequence of strings extracted from each frame data buffer using the default encoding.