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(); } }