onAdd method

@override void onAdd(LogEntry entry)

Handles an accepted entry. Called only before close.

Implementation

@override
void onAdd(LogEntry entry) {
  final lengthBefore = _queue.length;
  _queue.add(entry);
  _accepted++;
  // The queue did not grow: the oldest entry was dropped, its outcome is known.
  if (_queue.length == lengthBefore) _settled++;
  if (_isDrainScheduled) return;
  _isDrainScheduled = true;
  scheduleMicrotask(() {
    _isDrainScheduled = false;
    _startDraining();
  });
}