@visibleForTesting Future<int> getPendingAcks() async { var acks = 0; await _ackLock.synchronized(() async { acks = _pendingAcks; }); return acks; }