Method Process
Process(IObservable<byte[]>)
Creates a publisher socket for transmitting an observable sequence of binary coded messages.
public IObservable<byte[]> Process(IObservable<byte[]> source)Parameters
sourceIObservable<byte[]>The sequence of binary coded messages to transmit.
Returns
- IObservable<byte[]>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of transmitting the binary coded messages over a publisher socket.
Process(IObservable<string>)
Creates a publisher socket for transmitting an observable sequence of string messages.
public IObservable<string> Process(IObservable<string> source)Parameters
sourceIObservable<string>The sequence of string messages to transmit.
Returns
- IObservable<string>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of transmitting the string messages over a publisher socket.
Process(IObservable<NetMQMessage>)
Creates a publisher socket for transmitting an observable sequence of multiple part messages.
public override IObservable<NetMQMessage> Process(IObservable<NetMQMessage> source)Parameters
sourceIObservable<NetMQMessage>The sequence of multiple part messages to transmit.
Returns
- IObservable<NetMQMessage>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of transmitting the multiple part messages over a publisher socket.