flushRemainingLogs function

Future<void> flushRemainingLogs({
  1. String? runId,
})

Implementation

Future<void> flushRemainingLogs({String? runId}) async {
  for (final key in _bufferGroups.keys.toList()) {
    final group = _bufferGroups[key]!;
    if (runId == null || group.runId == runId) {
      _triggerFlush(group);
      _bufferGroups.remove(key);
    }
  }

  while (_activeWrites.isNotEmpty) {
    await Future.wait(_activeWrites);
  }
}