Skip to content

Watchable

faststream.nats.subscriber.subscription.Watchable #

Bases: Protocol

stop async #

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

updates async #

updates(timeout)
Source code in faststream/nats/subscriber/subscription.py 
11
async def updates(self, timeout: float) -> Optional[Any]: ...