Skip to content

Watchable

faststream.nats.subscriber.adapters.Watchable #

Bases: Protocol

stop async #

stop()
Source code in faststream/nats/subscriber/adapters.py 
9
async def stop(self) -> None: ...

updates async #

updates(timeout)
Source code in faststream/nats/subscriber/adapters.py 
11
async def updates(self, timeout: float) -> Any | None: ...