Class Subscriber
Represents an operator that creates a subscriber socket for receiving a sequence of messages as part of the pub-sub pattern.
public class Subscriber : Source<NetMQMessage>
- Inheritance
-
Source<NetMQMessage>Subscriber
- Inherited Members
Properties
- ConnectionString
Gets or sets a value specifying the endpoints to attach the socket to.
- Topic
Gets or sets the topic that the socket will subscribe to.
Methods
- Generate()
Creates a subscriber socket for receiving an observable sequence of multiple part messages on the specified Topic.