pyrcf.utils.data_io_utils.pyrcf_subscriber

Classes

PyRCFSubscriberBase	Base subscriber class.
PyRCFSubscriberZMQ	A zmq subscriber to read data published using PyRCFPublisherZMQ.

Module Contents

class pyrcf.utils.data_io_utils.pyrcf_subscriber.PyRCFSubscriberBase

Bases: abc.ABC

Base subscriber class.

abstract read_raw() → str

Return raw string/bytes.

read_json() → Mapping[str, Any]

Return as python dict (json).

close()

Close subscriber cleanly.

class pyrcf.utils.data_io_utils.pyrcf_subscriber.PyRCFSubscriberZMQ(port: int = DEFAULT_ZMQ_PUBLISH_PORT, topic: str = '')

Bases: PyRCFSubscriberBase

A zmq subscriber to read data published using PyRCFPublisherZMQ.

context

socket

read_raw() → str

Return raw string/bytes.

close()

Close subscriber cleanly.

__del__()