[DART] Stream<T> 클래스 사용하기

import 'dart:async';

Stream<int> countStream(int count) async* {
  for (int i = 1; i <= count; i++) {
    print('countStream : $i');
    yield i;
  }
}

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

main() async {
  Stream<int> stream = countStream(10);
  int summary = await sumStream(stream);
  print(summary);
}