getPendingAcks method

  1. @visibleForTesting
Future<int> getPendingAcks()

Implementation

@visibleForTesting
Future<int> getPendingAcks() async {
  var acks = 0;

  await _ackLock.synchronized(() async {
    acks = _pendingAcks;
  });

  return acks;
}