Skip to content

PatchedMessage

faststream.nats.test.PatchedMessage #

Bases: Msg

ack async #

ack() -> None
Source code in faststream/nats/test.py 
140
141
async def ack(self) -> None:
    pass

ack_sync async #

ack_sync(timeout: float = 1) -> PatchedMessage
Source code in faststream/nats/test.py 
143
144
145
146
async def ack_sync(
    self, timeout: float = 1
) -> "PatchedMessage":  # pragma: no cover
    return self

in_progress async #

in_progress() -> None
Source code in faststream/nats/test.py 
154
155
async def in_progress(self) -> None:
    pass

nak async #

nak(delay: Union[int, float, None] = None) -> None
Source code in faststream/nats/test.py 
148
149
async def nak(self, delay: Union[int, float, None] = None) -> None:
    pass

term async #

term() -> None
Source code in faststream/nats/test.py 
151
152
async def term(self) -> None:
    pass