Product Guides Request a demo Open app

BufferedPublisher#

class BufferedPublisher( publisher: Publisher, buffer_size: int = 1000, )[source]#

Bases: ABC

Methods

`close`
`publish`
`publish_batch`

publish(

data: Measurement | Command,

**kwargs,

) → None[source]#

abstractmethod publish_batch() → None[source]#

close() → None[source]#