pickPendingItem method

Future<OutgoingMessage?> pickPendingItem(
  1. int t
)

Implementation

Future<OutgoingMessage?> pickPendingItem(int t) async {
  if (_sent.contains(t) || _pending.contains(t)) return null;

  if (_data[t] != null) {
    return _data[t];
  }

  return await pullFromDiskQueue(t);
}