streamTest

readme.md

streamTest

Created with <3 with dartpad.dev.

main.dart

void main() async {
  /// Initialize a stream of integers 0-9
  Stream<int> stream = countStream(10);

  /// Compute the sum of the stream of integers
  int sum = await sumStream(stream);

  /// Print the sum
  print(sum); // 45
}

Stream<int> countStream(int max) async* {
  for (int i = 0; i < max; i++) {
    print('i: $i');
    await Future.delayed(Duration(seconds: 2));
    yield i;
  }
}

Future<int> sumStream(Stream<int> stream) async {
  int sum = 0;
  await for (int value in stream) {
    sum += value;
    print('sum: $sum');
  }
  return sum;
}