PatchedMessage faststream.nats.testing.PatchedMessage # Bases: Msg ack async # ack() Source code in faststream/nats/testing.py 207 208async def ack(self) -> None: pass ack_sync async # ack_sync(timeout=1) Source code in faststream/nats/testing.py 210 211 212 213 214async def ack_sync( self, timeout: float = 1, ) -> "PatchedMessage": # pragma: no cover return self nak async # nak(delay=None) Source code in faststream/nats/testing.py 216 217async def nak(self, delay: Union[int, float, None] = None) -> None: pass term async # term() Source code in faststream/nats/testing.py 219 220async def term(self) -> None: pass in_progress async # in_progress() Source code in faststream/nats/testing.py 222 223async def in_progress(self) -> None: pass