pending method

Future<int> pending()

How many deliveries are queued, one per event per sink.

Implementation

Future<int> pending() async {
  await idle;
  final List<Map<String, Object?>> rows =
      await database.query('SELECT COUNT(*) AS n FROM $outboxTable');
  final Object? n = rows.first['n'];
  return n is int ? n : int.parse('$n');
}