runsWaitingOn method

@override Future<List<String>> runsWaitingOn(String topic, { int limit = 256, })

Lists runs waiting on a specific event topic.

Implementation

@override
/// Lists runs waiting on a specific event [topic].
Future<List<String>> runsWaitingOn(String topic, {int limit = 256}) async {
  final watchers = _watchersByTopic[topic];
  if (watchers != null && watchers.isNotEmpty) {
    return watchers.keys.take(limit).toList(growable: false);
  }
  final runs = _suspendedTopics[topic];
  if (runs == null) return const [];
  return runs.take(limit).toList(growable: false);
}