Source
void ackReceived(int receiveAckId, int startTime, int currentTime) {
if (receiveAckId == _lastWaitingAckId) {
_waitingAckCount = 0;
} else {
_waitingAckCount--;
}
subscriptions.forEach((String path, RespSubscribeController controller) {
if (controller._qosLevel > 0) {
controller.onAck(receiveAckId);
}
});
if (_sendingAfterAck) {
_sendingAfterAck = false;
prepareSending();
}
}