Class Response
Represents an operator that creates a response socket for receiving a sequence of request messages and transmitting generated responses.
Inherited Members
Namespace: Bonsai.ZeroMQ
Assembly: Bonsai.ZeroMQ.dll
Syntax
public class Response : Source<ResponseContext>
Properties
| Improve this Doc View SourceConnectionString
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
| Improve this Doc View SourceGenerate()
Creates a response socket for receiving an observable sequence of request messages and transmitting generated responses.
Declaration
public override IObservable<ResponseContext> Generate()
Returns
Type | Description |
---|---|
IObservable<ResponseContext> | An observable sequence of ResponseContext objects representing received requests. |
Overrides
Generate(IObservable<NetMQMessage>)
Creates a response socket that returns all received requests and transmits an observable sequence of multiple part response messages.
Declaration
public IObservable<NetMQMessage> Generate(IObservable<NetMQMessage> source)
Parameters
Type | Name | Description |
---|---|---|
IObservable<NetMQ.NetMQMessage> | source | The sequence of NetMQ.NetMQMessage objects representing the multiple part response messages to transmit. |
Returns
Type | Description |
---|---|
IObservable<NetMQ.NetMQMessage> | An observable sequence of NetMQ.NetMQMessage objects representing multiple part requests received from the response socket. |
Generate(IObservable<Byte[]>)
Creates a response socket that returns all received requests and transmits an observable sequence of binary-coded response messages.
Declaration
public IObservable<NetMQMessage> Generate(IObservable<byte[]> source)
Parameters
Type | Name | Description |
---|---|---|
IObservable<Byte[]> | source | The sequence of binary-coded response messages to transmit. |
Returns
Type | Description |
---|---|
IObservable<NetMQ.NetMQMessage> | An observable sequence of NetMQ.NetMQMessage objects representing multiple part requests received from the response socket. |
Generate(IObservable<String>)
Creates a response socket that returns all received requests and transmits an observable sequence of String response messages.
Declaration
public IObservable<NetMQMessage> Generate(IObservable<string> source)
Parameters
Type | Name | Description |
---|---|---|
IObservable<String> | source | The sequence of String response messages to transmit. |
Returns
Type | Description |
---|---|
IObservable<NetMQ.NetMQMessage> | An observable sequence of NetMQ.NetMQMessage objects representing multiple part requests received from the response socket. |