Dart 튜토리얼 15편: Stream 완전 가이드(async/await·using streams·creating streams)

Why#

NOTE

Stream을 처음 보면 “for 문인데 await가 붙어 있네?”처럼 느껴질 수 있습니다.
관점을 단순하게 잡으면, 이후 문법과 API가 훨씬 빠르게 연결됩니다.

What#

NOTE

스트림은 “비동기 이벤트의 시퀀스”입니다.
동기 Iterable¹⁰이 “다음 값을 요청하면 받는” 구조라면, 스트림은 “다음 값이 준비되면 알려주는” 구조로 설명됩니다.

How#

TIP

스트림의 이벤트를 받는 기본 패턴은 await for입니다.

1
Future<int> sumStream(Stream<int> stream) async {
2
  var sum = 0;
3
  await for (final value in stream) {
4
    sum += value;
5
  }
6
  return sum;
7
}

이 함수는 “스트림에서 값이 하나씩 들어올 때마다” 누적하고, 스트림이 끝나면 합계를 반환합니다.

Watch out#

WARNING

await for는 async¹¹ 함수 안에서만 사용할 수 있습니다.
즉, 스트림을 반복문으로 받고 싶다면 “함수 자체가 비동기”여야 합니다.

결론: Stream은 “비동기 Iterable”로 생각하고, 기본 소비는 await for로 시작합니다.

Why#

NOTE

스트림은 데이터 이벤트뿐 아니라 에러 이벤트도 전달할 수 있습니다.
이 에러를 놓치면 루프가 중단되고, 호출자는 “왜 끝났는지” 모르게 됩니다.

What#

NOTE

await for로 읽는 스트림에서 에러가 발생하면, 그 에러는 루프 문에서 던져집니다.
따라서 try/catch로 루프를 감싸서 처리하는 패턴이 제시됩니다.

How#

TIP

다음 예시는 반복 도중 에러를 던지고, try/catch에서 처리합니다.

1
Future<int> sumStream(Stream<int> stream) async {
2
  var sum = 0;
3
  try {
4
    await for (final value in stream) {
5
      sum += value;
6
    }
7
  } catch (e) {
8
    return -1;
9
  }
10
  return sum;
11
}
12

13
Stream<int> countStream(int to) async* {
14
  for (int i = 1; i <= to; i++) {
15
    if (i == 4) {
16
      throw Exception('Intentional exception');
17
    } else {
18
      yield i;
19
    }
20
  }
21
}
22

23
void main() async {
24
  var stream = countStream(10);
25
  var sum = await sumStream(stream);
26
  print(sum); // 에러가 발생했으므로 -1을 출력한다.
27
}

Watch out#

WARNING

에러가 발생하면 스트림이 “끝나기 전이라도” 루프가 종료될 수 있습니다.
즉, 에러 처리 전략(예: 실패 시 기본값 반환)을 함수 수준에서 결정해 둬야 합니다.

결론: 스트림의 에러는 루프에서 던져지므로, try/catch로 루프를 감싸는 패턴을 기본으로 둡니다.

Why#

NOTE

스트림을 직접 await for로 모두 구현하면 가능은 하지만, 흔한 작업은 이미 메서드로 제공됩니다.
기본 메서드를 아는 것만으로도 코드가 짧아집니다.

What#

NOTE

스트림에는 Future를 반환하는 여러 메서드가 있고, 예시로 lastWhere()가 제시됩니다.

How#

TIP

다음 코드는 “마지막 양수”를 구하는 예시입니다.

1
Future<int> lastPositive(Stream<int> stream) => stream.lastWhere((x) => x >= 0);

Watch out#

WARNING

이런 메서드는 내부적으로 스트림을 끝까지 소비할 수 있습니다.
따라서 “언제 끝나는 스트림인지”가 불분명한 경우에는, 먼저 스트림이 종료되는 조건을 확인해야 합니다.

결론: 기본 스트림 메서드를 익히면, 같은 작업을 더 짧고 읽기 쉽게 표현할 수 있습니다.

Why#

NOTE

스트림 소비는 빠르게 익힐 수 있지만, 스트림 생성은 선택지가 많아 막히기 쉽습니다.
그래서 생성 방식도 “자주 쓰는 순서”로 정리해두는 편이 좋습니다.

What#

NOTE

스트림은 다음 방식으로 만들 수 있다고 정리됩니다.
기존 스트림을 변환하거나, async* 생성기 함수를 사용하거나, StreamController를 사용하는 방식입니다.

How#

TIP

1. 기존 스트림 변환: Stream.periodic()로 만든 스트림을 map()¹²으로 변환할 수 있습니다.

1
var counterStream = Stream<int>.periodic(
2
  const Duration(seconds: 1),
3
  (x) => x,
4
).take(15);
5

6
// 각 이벤트 값을 두 배로 만든 새 스트림
7
var doubleCounterStream = counterStream.map((int x) => x * 2);
8
doubleCounterStream.forEach(print);

2. async* 생성기: 시간 간격으로 숫자를 내보내는 스트림을 만들 수 있습니다.

1
Stream<int> timedCounter(Duration interval, [int? maxCount]) async* {
2
  int i = 0;
3
  while (true) {
4
    await Future.delayed(interval);
5
    yield i++;
6
    if (i == maxCount) break;
7
  }
8
}

3. StreamController: 여러 곳에서 이벤트를 넣어야 한다면 컨트롤러를 사용할 수 있습니다.

1
Stream<int> timedCounter(Duration interval, [int? maxCount]) {
2
  var controller = StreamController<int>();
3
  int counter = 0;
4
  void tick(Timer timer) {
5
    counter++;
6
    controller.add(counter); // 스트림에 이벤트로 값을 보낸다.
7
    if (maxCount != null && counter >= maxCount) {
8
      timer.cancel();
9
      controller.close(); // 스트림을 종료한다.
10
    }
11
  }
12

13
  Timer.periodic(interval, tick);
14
  return controller.stream;
15
}

Watch out#

WARNING

StreamController 예시에는 “구독자가 없는데도 시작하는 등 구현이 올바르지 않은(FLAWED) 예시”가 함께 제시됩니다.
즉, 컨트롤러 기반 스트림은 “언제 시작/중지할지”와 “일시정지(pause)” 같은 동작까지 고려해야 합니다.

결론: 스트림 생성은 “변환 → async* → StreamController” 순서로 접근하고, 컨트롤러는 동작 규칙까지 포함해 설계합니다.