chunk method

@override Future<void> chunk(int size, Future<void> callback(List<T> items))

Process results in chunks

Implementation

@override
Future<void> chunk(
  int size,
  Future<void> Function(List<T> items) callback,
) async {
  int page = 1;
  List<T> results;
  do {
    final q = clone();
    q.skip((page - 1) * size).take(size);

    results = await q.get();

    if (results.isNotEmpty) {
      await callback(results);
    }

    page++;
  } while (results.length == size);
}