Method Process

Namespace

Bonsai.ZeroMQ

Assembly

Bonsai.ZeroMQ.dll

Process(IObservable<NetMQMessage>)

Extracts all the identity frames from each multiple part message in an observable sequence, up to and including the empty delimiter frame.

public override IObservable<NetMQFrame> Process(IObservable<NetMQMessage> source)

Parameters

source IObservable<NetMQMessage>

An observable sequence of NetMQ.NetMQMessage objects representing the multiple part messages from which to extract the identity frames.

Returns

IObservable<NetMQFrame>

A sequence of NetMQ.NetMQFrame objects representing all the identity frames in each message of the source sequence.