nemo_relay.subscribers

View as Markdown

Generated from python/nemo_relay/subscribers.py.

Module nemo_relay.subscribers.

Global event subscriber registration.

Functions

register

1def register(name: str, callback: 'Callable[[Event], None]') -> None

Register a global event subscriber.

deregister

1def deregister(name: str) -> bool

Remove a previously registered global subscriber.

flush

1def flush() -> None

Wait for queued callbacks and registered managed terminal publications.

flush_async

1async def flush_async() -> None

Wait asynchronously for queued callbacks and managed terminal events.