flush method

Future<void> flush()

Flushes any events persisted in the outbox.

Implementation

Future<void> flush() async {
  _ensureConfig();
  await _outbox.flushWith(_pipeline!);
}