Class Dealer

Represents an operator that creates a dealer socket for transmitting a sequence of messages and receiving responses asynchronously while maintaining load balance.

Inheritance

Object

Combinator<NetMQ.NetMQMessage, NetMQ.NetMQMessage>

Dealer

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 Dealer : Combinator<NetMQMessage, 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

Methods

Process(IObservable<NetMQMessage>)

Creates a dealer socket for transmitting an observable sequence of request messages and receiving responses asynchronously while maintaining load balance.

Declaration

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

Parameters

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

Returns

Type	Description
IObservable<NetMQ.NetMQMessage>	An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the dealer socket.

Overrides

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

Process(IObservable<Byte[]>)

Creates a dealer socket for transmitting an observable sequence of binary-coded requests and receiving responses asynchronously while maintaining load balance.

Declaration

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

Parameters

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

Returns

Type	Description
IObservable<NetMQ.NetMQMessage>	An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the dealer socket.

Process(IObservable<String>)

Creates a dealer socket for transmitting an observable sequence of String requests and receiving responses asynchronously while maintaining load balance.

Declaration

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

Parameters

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

Returns

Type	Description
IObservable<NetMQ.NetMQMessage>	An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the dealer socket.