countStream<R> function

Future<int> countStream<R>(Stream<R> stream, { required int count(R response), int maxPages = 20, })

Counts items from a paginated server stream with a maximum page cap. Only accumulates the count, not the items themselves.

Implementation

Future<int> countStream<R>(
  Stream<R> stream, {
  required int Function(R response) count,
  int maxPages = 20,
}) async {
  var total = 0;
  var pages = 0;
  await for (final response in stream) {
    final c = count(response);
    total += c;
    if (++pages >= maxPages || c == 0) break;
  }
  return total;
}