[11] Future와 Stream

2025-09-30

Future

• 하나의 작업에 대해 값이나 이벤트가 한 번 발생하는 단일 비동기 작업에 사용.
• 작업당 결과값을 한 번만 받을 수 있다.

Future의 반환

Future<String> introduce(String name) async {
	print('$name의 자기소개 시작 !');
  
  await Future.delayed(Duration(seconds: 2), () {
    print('안녕 ? 나는 $name ~');
  });
	
	print('$name의 자기소개 끝 !');
  
  return '이름은 $name ~';
}

void main() async {
  var riverfuture = await introduce('강미래');
  var riverpresent = await introduce('강현재');
  print('나의 $riverfuture 너의 $riverpresent');
}

• 하나의 작업에 결과값이 여러 번 나오는 경우는 어떻게 할까?
• Stream을 사용하여 결과값을 받는다.

Stream

• 하나의 작업에 대해 값이나 이벤트가 여러 번 발생하는 경우에 사용
• 비동기 연산의 결과값이 여러 번 반환되는 경우 그 값을 순차적으로 받기 위해 사용
• 결과값을 한 번 반환하고 나면 실행이 종료되는 Future 와 다르게 직접 실행을 종료해 주어야 실행이 종료되고, 실행을 종료해 주지 않으면 계속 실행된다.
• 결과값의 타입은 Stream

Steam<int> number = Steam.value(1);
Steam<String> name = Steam.value('강미래');
Steam<bool> isOddNumber = Steam.value(1.isOdd);

• Steam<bool> 은 bool 이랑 같은데 단지 Steam 이 감싸고 있을 뿐이라고 생각하면 된다.
• 아래의 예제를 통해 자세히 알아보자.

Stream<String> emitNames() async* {
  yield '강미래';
  yield '강현재';
  yield '강과거';
}

• yield는 값을 방출하도록 하는 키워드
• Future 를 반환 타입으로 갖는 함수는 async 를 사용했는데, Stream 을 반환 타입으로 갖는 함수는 async* 을 사용한다.

Stream<String> emitNames() async* {
  yield '강미래';
  yield '강현재';
  yield '강과거';
}

void main() {
  int number = 1;
  
  emitNames().listen((name) {
    print('$number번째는 $name ~');
    number += 1;
  });
}

• listen()은 지속적으로 값을 받을 수 있다.
• 여기서는 yield 를 통해 방출되는 값을 받기 위해 사용