Class Publisher

Represents an operator that creates a publisher socket for transmitting a sequence of messages as part of the pub-sub pattern.

Inheritance

Object

Combinator<NetMQ.NetMQMessage, NetMQ.NetMQMessage>

Sink<NetMQ.NetMQMessage>

Publisher

Inherited Members

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

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 Publisher : Sink<NetMQMessage>

Properties

ConnectionString

Gets or sets a value specifying the endpoints to attach the socket to.

Declaration

[TypeConverter(typeof(ConnectionStringConverter))]
public string ConnectionString { get; set; }

Property Value

Type	Description
String

Topic

Gets or sets the topic under which to publish each sent message.

Declaration

public string Topic { get; set; }

Property Value

Type	Description
String

Methods

Process(IObservable<NetMQMessage>)

Creates a publisher socket for transmitting an observable sequence of multiple part messages.

Declaration

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

Parameters

Type	Name	Description
IObservable<NetMQ.NetMQMessage>	source	The sequence of multiple part messages to transmit.

Returns

Type	Description
IObservable<NetMQ.NetMQMessage>	An observable sequence that is identical to the source sequence but where there is an additional side effect of transmitting the multiple part messages over a publisher socket.

Overrides

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

Process(IObservable<Byte[]>)

Creates a publisher socket for transmitting an observable sequence of binary coded messages.

Declaration

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

Parameters

Type	Name	Description
IObservable<Byte[]>	source	The sequence of binary coded messages to transmit.

Returns

Type	Description
IObservable<Byte[]>	An observable sequence that is identical to the source sequence but where there is an additional side effect of transmitting the binary coded messages over a publisher socket.

Process(IObservable<String>)

Creates a publisher socket for transmitting an observable sequence of String messages.

Declaration

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

Parameters

Type	Name	Description
IObservable<String>	source	The sequence of String messages to transmit.

Returns

Type	Description
IObservable<String>	An observable sequence that is identical to the source sequence but where there is an additional side effect of transmitting the String messages over a publisher socket.

See Also

Subscriber