[Flutter] Stream을 이용한 비동기 프로그래밍

Stream을 이용한 비동기 프로그래밍

Stream, StreamController를 이용한 비동기 프로그래밍을 정리

• dartpad로 실행하기

1. Stream 클래스의 fromIterable

fromIterable 함수의 파라메터로  
iterable(==list형) 값들을 넘겨서 비동기 프로그래밍에서
순차적인 프로그래밍을 구현할 수 있다. 
listen()에서 값을 처리한다. 

Future<String> doAsyncWork(int n, int delay) async {
    // Future 함수에서 await를 사용하면 비동기에서 순차적으로 처리가능하다.
    // await를 호출한 함수는 async로 정의해주어야 한다.
    await Future.delayed(Duration(seconds: delay));
    print("$n work launched!");
    return "$n번 작업이 $delay초 걸렸습니다";
  }

  int doSyncWork() => 4 * 3;

  var worklist = [
    await doAsyncWork(3, 5),
    await doAsyncWork(100, 1),
    doSyncWork()
  ];
  Stream.fromIterable(worklist).listen((i) {
    print('$i');
  });

2. Stream 클래스의 periodic

periodic 함수의 파라메터로  
Duration을 넘겨서 타이머 역할을 수행할 수 있다.  
listen()에서 값을 처리한다. 
take() 함수로 반복횟수를 제한할 수 있다. 

  int count = 0;
  int sum = 0;
  Stream.periodic(Duration(seconds: 3), (_) {
    count++;
  }) // n 시간단위로 할 일. Duration만 필수임.
      .take(6) // 6번까지만 take 없으면 무한대
      .listen((event) {
    // tick 이벤트가 발생할 때 핸들러
    sum += count;
    print("count: $count => sum : $sum");
  });

3. StreamController 클래스

broadcast()를 통한 StreamController 객체 생성. 
Event 송신, 수신과 같은 기능을 구현할 수 있다(이벤트핸들러 구현). 
Stream 클래스의 add()는 이벤트 발생
listen()에서 값을 처리한다. 
종료시 StreamController의 close() 메소드 호출 필요

  var sender = StreamController.broadcast();
  var eventhandler = sender.stream;
  eventhandler.listen((event) {
    if (event is String) {
      if (event == "quit") {
        sender.close();
      }
    }
    print("event is => $event");
  });

  print("==== event 보내기");
  sender.add("event");
  sender.add([1, 2, 3]);
  sender.add(12.023);
  sender.add("quit");

  sender.add("quit이후 event 처리안됨");

전체소스

import 'dart:async';

void main(List<String> args) async {
  // Stream 클래스의
  // fromIterable는
  // 비동기 작업을 순차적으로 처리할 때 사용한다.
  fromIterableTest();

  // Stream 클래스의
  // periodic는
  // 타이머와 유사하게 일정시간 반복되는 작업을 할 경우
  // 사용한다.
  periodicTest();

  // 이벤트를 발생시키고 기다리며 처리해야 할 경우 사용
  stramControllerTest();
}

void stramControllerTest() {
  var sender = StreamController.broadcast();
  var eventhandler = sender.stream;
  eventhandler.listen((event) {
    if (event is String) {
      if (event == "quit") {
        sender.close();
      }
    }
    print("event is => $event");
  });

  print("==== event 보내기");
  sender.add("event");
  sender.add([1, 2, 3]);
  sender.add(12.023);
  sender.add("quit");

  sender.add("quit이후 event 처리안됨");
}

void periodicTest() {
  int count = 0;
  int sum = 0;
  Stream.periodic(Duration(seconds: 3), (_) {
    count++;
  }) // n 시간단위로 할 일. Duration만 필수임.
      .take(6) // 6번까지만 take 없으면 무한대
      .listen((event) {
    // tick 이벤트가 발생할 때 핸들러
    sum += count;
    print("count: $count => sum : $sum");
  });
}

Future fromIterableTest() async {
  // 지연작업을 위한 Future 함수(비동기 작업)
  Future<String> doAsyncWork(int n, int delay) async {
    // Future 함수에서 await를 사용하면 비동기에서 순차적으로 처리가능하다.
    // await를 호출한 함수는 async로 정의해주어야 한다.
    await Future.delayed(Duration(seconds: delay));
    print("$n work launched!");
    return "$n번 작업이 $delay초 걸렸습니다";
  }

  int doSyncWork() => 4 * 3;
  var worklist = [
    await doAsyncWork(3, 5),
    await doAsyncWork(100, 1),
    doSyncWork()
  ];
  Stream.fromIterable(worklist).listen((i) {
    print('$i');
  });
}