async def _process_ack(self, msg):
pub_ack = protocol.PubAck()<EOL>pub_ack.ParseFromString(msg.data)<EOL>if not self._pending_pub_acks_queue.empty():<EOL><INDENT>await self._pending_pub_acks_queue.get()<EOL><DEDENT>try:<EOL><INDENT>cb = self._pub_ack_map[pub_ack.guid]<EOL>await cb(pub_ack)<EOL>del self._pub_ack_map[pub_ack.guid]<EOL><DEDENT>except KeyError:<EOL><INDENT>return<EOL><DEDENT>except:<EOL><INDENT>return<EOL><DEDENT>
Receives acks from the publishes via the _STAN.acks subscription.