NumpyInMemoryPublisher#

class NumpyInMemoryPublisher( maxlen: int, value_dtype: Any = np.float32, )[source]#

String-valued channels are stored in a plain deque; a float32 ring cannot hold them.

Attributes

`channel_names`	Return an insertion-ordered snapshot of all channel names currently in the buffer.
`size_bytes`	Return the current memory in bytes.

Methods

`close`	Close the publisher and clear all buffers with thread synchronization.
`get`	Return the trailing `length` samples for `channel_name`.
`publish`	Publish measurement data to the buffers with thread synchronization.