[DART] Stream<T> 클래스 : async*/yield 키워드 사용하기

import 'dart:async';

void main() async {
  Stream<String> stream = await getStream(['A', 'B', 'C', 'D', 'E']);

  int count = await Print(stream);

  print(count);
}

const Duration duration = Duration(seconds: 1);

Stream<String> getStream(Iterable<String> itemIterable) async* {
  for (String item in itemIterable) {
    await Future.delayed(duration);

    yield item;
  }
}

Future<int> Print(Stream<String> stream) async {
  int count = 0;

  await for (String item in stream) {
    print(item);

    count++;
  }

  return count;
}