Method Process

Namespace

Bonsai.ZeroMQ

Assembly

Bonsai.ZeroMQ.dll

Process(IObservable<NetMQFrame>)

Creates a multiple part message from an observable sequence of individual message frames.

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

Parameters

source IObservable<NetMQFrame>

A sequence of NetMQ.NetMQFrame objects representing the individual message parts.

Returns

IObservable<NetMQMessage>

An observable sequence containing a single NetMQ.NetMQMessage object representing the created multiple part message.

Process(IObservable<byte[]>)

Creates a multiple part message from an observable sequence of individual data buffers.

public IObservable<NetMQMessage> Process(IObservable<byte[]> source)

Parameters

source IObservable<byte[]>

A sequence of byte-array objects representing the individual message parts.

Returns

IObservable<NetMQMessage>

An observable sequence containing a single NetMQ.NetMQMessage object representing the created multiple part message.

Process(IObservable<string>)

Creates a multiple part message from an observable sequence of individual message parts.

public IObservable<NetMQMessage> Process(IObservable<string> source)

Parameters

source IObservable<string>

A sequence of string objects representing the individual message parts.

Returns

IObservable<NetMQMessage>

An observable sequence containing a single NetMQ.NetMQMessage object representing the created multiple part message.