We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 06735d7 commit 41ce2c9Copy full SHA for 41ce2c9
nats/aio/msg.py
@@ -77,6 +77,13 @@ def header(self) -> Optional[Dict[str, str]]:
77
"""
78
return self.headers
79
80
+ @property
81
+ def is_acked(self) -> bool:
82
+ """
83
+ Have we sent a terminal ack message (not in-progress) in response to this original message?
84
85
+ return self._ackd
86
+
87
@property
88
def sid(self) -> int:
89
0 commit comments