Class Push
Represents an operator that creates a push socket for transmitting a sequence of messages as part of the push-pull pattern.
public class Push : Sink<NetMQMessage>
- Inheritance
-
Sink<NetMQMessage>Push
- Inherited Members
Properties
- ConnectionString
Gets or sets a value specifying the endpoints to attach the socket to.
Methods
- Process(IObservable<NetMQMessage>)
Creates a push socket for transmitting an observable sequence of multiple part messages.
- Process(IObservable<byte[]>)
Creates a push socket for transmitting an observable sequence of binary coded messages.
- Process(IObservable<string>)
Creates a push socket for transmitting an observable sequence of string messages.