Method Process
Process(IObservable<byte[]>)
Creates a dealer socket for transmitting an observable sequence of binary-coded requests and receiving responses asynchronously while maintaining load balance.
public IObservable<NetMQMessage> Process(IObservable<byte[]> source)Parameters
sourceIObservable<byte[]>The sequence of binary-coded request messages to transmit.
Returns
- IObservable<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.
public IObservable<NetMQMessage> Process(IObservable<string> source)Parameters
sourceIObservable<string>The sequence of string request messages to transmit.
Returns
- IObservable<NetMQMessage>
An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the dealer socket.
Process(IObservable<NetMQMessage>)
Creates a dealer socket for transmitting an observable sequence of request messages and receiving responses asynchronously while maintaining load balance.
public override IObservable<NetMQMessage> Process(IObservable<NetMQMessage> source)Parameters
sourceIObservable<NetMQMessage>The sequence of multiple part request messages to transmit.
Returns
- IObservable<NetMQMessage>
An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the dealer socket.