Method Generate
Generate()
Generates an observable sequence of requests received from a router socket, where the identity of each request is tracked so that responses can be matched even if computed concurrently.
public override IObservable<ResponseContext> Generate()Returns
- IObservable<ResponseContext>
An observable sequence of ResponseContext objects representing received requests.
Generate(IObservable<NetMQMessage>)
Creates a router socket that appends an identity to all received messages and reads it back from outgoing messages to determine the peer the message should be routed to.
public IObservable<NetMQMessage> Generate(IObservable<NetMQMessage> source)Parameters
sourceIObservable<NetMQMessage>The sequence of NetMQ.NetMQMessage objects representing the multiple part response messages to route back to peers.
Returns
- IObservable<NetMQMessage>
An observable sequence of NetMQ.NetMQMessage objects representing multiple part requests received from the router socket.