deliverAll method

Future<DVCaptureDelivery> deliverAll()

Delivers until the consumer has reached the head of the log.

Implementation

Future<DVCaptureDelivery> deliverAll() async {
  final List<String> codes = <String>[];
  int delivered = 0;
  int read = 0;
  while (true) {
    final DVCaptureDelivery run = await deliverOnce();
    codes.addAll(run.codes);
    delivered += run.delivered;
    read += run.read;
    if (run.read < batchSize) {
      return DVCaptureDelivery(
        delivered: delivered,
        checkpoint: run.checkpoint,
        codes: codes,
        read: read,
      );
    }
  }
}