Class ToMessage

Represents an operator that creates a multiple part message from an observable sequence.

Inheritance

Object

Combinator<NetMQ.NetMQFrame, NetMQ.NetMQMessage>

ToMessage

Inherited Members

Combinator<NetMQFrame, NetMQMessage>.Process(IObservable<NetMQFrame>)

Object.ToString()

Object.Equals(Object)

Object.Equals(Object, Object)

Object.ReferenceEquals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Namespace: Bonsai.ZeroMQ

Assembly: Bonsai.ZeroMQ.dll

Syntax

public class ToMessage : Combinator<NetMQFrame, NetMQMessage>

Methods

Process(IObservable<NetMQFrame>)

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

Declaration

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

Parameters

Type	Name	Description
IObservable<NetMQ.NetMQFrame>	source	A sequence of NetMQ.NetMQFrame objects representing the individual message parts.

Returns

Type	Description
IObservable<NetMQ.NetMQMessage>	An observable sequence containing a single NetMQ.NetMQMessage object representing the created multiple part message.

Overrides

Bonsai.Combinator<NetMQ.NetMQFrame, NetMQ.NetMQMessage>.Process(System.IObservable<NetMQ.NetMQFrame>)

Process(IObservable<Byte[]>)

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

Declaration

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

Parameters

Type	Name	Description
IObservable<Byte[]>	source	A sequence of byte-array objects representing the individual message parts.

Returns

Type	Description
IObservable<NetMQ.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.

Declaration

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

Parameters

Type	Name	Description
IObservable<String>	source	A sequence of String objects representing the individual message parts.

Returns

Type	Description
IObservable<NetMQ.NetMQMessage>	An observable sequence containing a single NetMQ.NetMQMessage object representing the created multiple part message.