Method Process

Namespace

Bonsai.ZeroMQ

Assembly

Bonsai.ZeroMQ.dll

Process(IObservable<SocketInfo>)

Creates and starts a proxy with the specified back-end socket.

public override IObservable<Unit> Process(IObservable<SocketInfo> source)

Parameters

source IObservable<SocketInfo>

A sequence of SocketInfo objects representing information about the front-end socket to use for the proxy. A new proxy will be created and started for each value in the sequence.

Returns

IObservable<Unit>

An observable sequence whose observers will never get called. The proxy is started purely for its side-effects of routing messages from the front-end to the back-end sockets.