xdas.io.asn.ZMQPublisher

class xdas.io.asn.ZMQPublisher(address)

A class to stream data using ZeroMQ.

Parameters:

address (str) – The address to bind the ZeroMQ socket.

address

The address where the ZeroMQ is bound to.

Type:

str

submit(da)

Submits the data array for publishing.

Examples

>>> import xdas as xd
>>> from xdas.io.asn import ZMQPublisher

>>> da = xd.synthetics.dummy()

>>> port = xd.io.get_free_port()
>>> address = f"tcp://localhost:{port}"
>>> publisher = ZMQPublisher(address)
>>> chunks = xd.split(da, 10)
>>> for chunk in chunks:
...     publisher.submit(chunk)

__init__(address)

Methods

__init__(address)
submit(da)	Publish da over ZMQ.
write(da)	Alias for submit().

Attributes

header

The last welcome-message header dict sent to new subscribers.