7. Dart - Async Programming - Stream

** Dart - Async Programming - Stream **

 

import 'dart:async'; void main() { //Stream // - 지속적으로 계속 반환값을 받을 수 있음 //1. Stream. listener1개 선언 streamControl(); //2. Stream. listener n개 선언하기 // stream에 where절 사용하기 streamControlN(); //3. 함수형 Stream streamFunction(); //4. 함수형 Stream에 Future사용하기 streamFutureFunction(); //5. 함수형 Stream에 yield 사용하기 streamYield(); } //--------------------------------------------------------------------------- //1. Stream. listener1개 선언 //--------------------------------------------------------------------------- void streamControl(){ final controller = StreamController(); //import 'dart:async'; final stream = controller.stream; //listen : 기다리다가 값(val)이 들어 오면 수행 final streamListener1 = stream.listen((val) { print('Listner 1: $val'); }); controller.sink.add(1); controller.sink.add(2); } //--------------------------------------------------------------------------- //2. Stream. listener n개 선언하기 //--------------------------------------------------------------------------- void streamControlN(){ final controller = StreamController(); //import 'dart:async'; //asBroadcastStream // - stream에 대한 listener는 여러게 만들 수 있음 final stream = controller.stream.asBroadcastStream(); //listen : 기다리다가 값(val)이 들어 오면 수행 final streamListener1 = stream.where((val)=>val%2==0).listen((val) { print('Listner 1: $val'); }); final streamListener2 = stream.listen((val) { print('Listner 2: $val'); }); controller.sink.add(1); controller.sink.add(2); } //--------------------------------------------------------------------------- //3. 함수형 Stream //--------------------------------------------------------------------------- void streamFunction(){ //1. 일반적인 함수 - return을 한번만 받음 print(cal(10)); //결과 : 10 //2. Stream으로 return받기 // Stream형태 이므로 print문으로 출력할 수 없음 print(mul(10)); //결과: Instance of '_ControllerStream<int>' mul(10).listen((val) {print(val);}); //출력: 10,20,30,40 } int cal(int num) { for(int i=1; i<5; i++) { return i*num; } return 0; } Stream<int> mul(int num) async* { for(int i=1;i<5; i++) {yield i*num;} } //--------------------------------------------------------------------------- //4. 함수형 Stream에 Future사용하기 //--------------------------------------------------------------------------- void streamFutureFunction(){ //1. async함수 호출이므로 script가 두 줄이 바로 실행 됨 mul(2).listen((val) {print('cal(2) : $val');}); mul(4).listen((val) {print('cal(2) : $val');}); } Stream<int> mul2(int num) async* { for(int i=1;i<5; i++) { //yield : 반환후에도 함수에 계속유지됨 yield i*num; await Future.delayed(Duration(seconds:1)); } } //--------------------------------------------------------------------------- //5. 함수형 Stream에 yield 사용하기 //--------------------------------------------------------------------------- void streamYield() { playAllStream().listen((val){print(val);}); } Stream<int> playAllStream() async* { //yield* - 호출하는 함수가 모든 값을 다 가져올때(return)까지 기다린다. yield* mul2(1); yield* mul2(1000); }