wotpy.protocols.zenoh.handlers.event

Zenoh handler for Event subscriptions.

Classes

EventZenohHandler(zenoh_server[, callback_ms])

Zenoh handler for Event subscriptions.

class wotpy.protocols.zenoh.handlers.event.EventZenohHandler(zenoh_server, callback_ms=None)

Bases: BaseZenohHandler

Zenoh handler for Event subscriptions.

DEFAULT_CALLBACK_MS = 2000

DEFAULT_JITTER = 0.2

build_event_topic(thing, event)

Returns the Zenoh topic for Event emissions.

async init()

Initializes the Zenoh handler. Called when the Zenoh runner starts.

async teardown()

Destroys the Zenoh handler. Called when the Zenoh runner stops.