NatsMessage

async def decode(self) -> Optional["DecodedMessage"]:
    """Serialize the message by lazy decoder."""
    # TODO: make it lazy after `decoded_body` removed
    return self._decoded_body

async def ack(self) -> None:
    # Check `self.raw_message._ackd` instead of `self.committed`
    # to be compatible with `self.raw_message.ack()`
    if not self.raw_message._ackd:
        await self.raw_message.ack()
    await super().ack()

async def nack(
    self,
    delay: Union[int, float, None] = None,
) -> None:
    if not self.raw_message._ackd:
        await self.raw_message.nak(delay=delay)
    await super().nack()

async def reject(self) -> None:
    if not self.raw_message._ackd:
        await self.raw_message.term()
    await super().reject()

async def in_progress(self) -> None:
    if not self.raw_message._ackd:
        await self.raw_message.in_progress()