runBatch method

  1. @override
FutureOr<void> runBatch(
  1. FutureOr<void> batch(
    1. ModelBatchRef ref
    ),
  2. int splitLength
)
override

Processes a batch for execution.

Create an adapter-specific ModelBatchRef that inherits ModelBatchRef internally, create a ModelBatchDocument from the ModelBatchRef.read, pass it as an argument to batch, and execute batch batch and execute batch.

Split batches by specifying splitLength.

バッチを実行するための処理を行います。

内部でModelBatchRefを継承したアダプター専用のModelBatchRefを作成し、そのModelBatchRef.readからModelBatchDocumentを作成、それをそのままbatchの引数に渡し、batchを実行するようにしてください。

splitLengthを指定してバッチを分割することができます。

Implementation

@override
FutureOr<void> runBatch(
  FutureOr<void> Function(
    ModelBatchRef ref,
  ) batch,
  int splitLength,
) async {
  _assert();
  final ref = LocalModelBatchRef._();
  await batch.call(ref);
  await wait(
    ref._batchList.map((tmp) => tmp.call()),
  );
}