chunked method

Stream<List<T>> chunked(int chunkSize)

Implementation

Stream<List<T>> chunked(int chunkSize) async* {
  List<T> chunk = [];
  await for (T e in this) {
    chunk.add(e);
    if (chunk.length >= chunkSize) {
      yield chunk;
      chunk = [];
    }
  }

  if (chunk.isNotEmpty) {
    yield chunk;
  }
}