flush method

Future<void> flush()

Drains the offline/batch queue and flushes every sink to its backend.

Waits for in-flight pipeline work first, so events emitted immediately before this call are included rather than racing it.

Implementation

Future<void> flush() async {
  await _chain;
  await _engine.flush();
}