[DART] Stream 클래스 사용하기

■ Stream<T> 클래스를 사용하는 방법을 보여준다.

▶ 예제 코드 (DART)


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);
}

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);

}