Method Process

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

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

source IObservable<byte[]>: The sequence of binary-coded request messages to transmit.

IObservable<NetMQMessage>: An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the request socket.

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

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

source IObservable<string>: The sequence of string request messages to transmit.

IObservable<NetMQMessage>: An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the request socket.

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

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

source IObservable<NetMQMessage>: The sequence of multiple part request messages to transmit.

IObservable<NetMQMessage>: An observable sequence of NetMQ.NetMQMessage objects representing multiple part responses received from the request socket.