Class Request

Represents an operator that creates a request socket for transmitting a sequence of request messages and receiving responses as part of the req-rep pattern.

Inheritance

Object

Combinator<Byte[], NetMQ.NetMQMessage>

Request

Inherited Members

Combinator<Byte[], NetMQMessage>.Process(IObservable<Byte[]>)

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 Request : Combinator<byte[], 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 request socket for transmitting an observable sequence of multiple part request messages and returns all received responses.

Declaration

public 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 request socket.

Process(IObservable<Byte[]>)

Creates a request socket for transmitting an observable sequence of binary-coded request messages and returns all received responses.

Declaration

public override 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 request socket.

Overrides

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

Process(IObservable<String>)

Creates a request socket for transmitting an observable sequence of String request messages and returns all received responses.

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 request socket.