Method Process

Namespace

Bonsai.ZeroMQ

Assembly

Bonsai.ZeroMQ.dll

Process(IObservable<byte[]>)

Converts a sequence of data buffers into an observable sequence of message frames.

public override IObservable<NetMQFrame> Process(IObservable<byte[]> source)

Parameters

source IObservable<byte[]>

A sequence of byte-array objects representing the individual data buffers.

Returns

IObservable<NetMQFrame>

A sequence of NetMQ.NetMQFrame objects representing individual message frames.

Process(IObservable<string>)

Converts a sequence of string objects into an observable sequence of message frames.

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

Parameters

source IObservable<string>

A sequence of string objects representing individual messages.

Returns

IObservable<NetMQFrame>

A sequence of NetMQ.NetMQFrame objects encoding individual messages.