write method

  1. @override
Future<void> write(
  1. DVCaptureBatch batch
)
override

Applies batch. Throwing leaves the checkpoint where it was, and the whole batch is delivered again (DV-CDC-001).

Implementation

@override
Future<void> write(DVCaptureBatch batch) async {
  for (final DVCapturedChange change in batch.changes) {
    await _apply(change, force: false);
  }
}