flushWith method

Future<void> flushWith(
  1. Reporter pipeline
)

Flushes pending events using the given reporter pipeline.

Implementation

Future<void> flushWith(Reporter pipeline) async {
  final items = await pending();
  for (final e in items) {
    final ok = await pipeline.send(e);
    if (ok) {
      await ack(e.id);
    }
  }
}