flush method

@override Future<void> flush()

Completes when the queue has been fully drained.

Drain semantics: the returned future also waits for logs published after this call, until the buffer becomes empty. Completes immediately when the publisher is idle or closed.

Implementation

@override
Future<void> flush() async {
  // flush гарантирует не только запись опубликованного (drain-семантика
  // базового flush), но и завершение инициализации: первый чанк с
  // meta-строкой уже на диске.
  await ready;
  await super.flush();
}