[Dart]Stream

🔎Stream이란?

스트림은 데이터나 이벤트가 들어오는 통로라고 생각하면 된다.

앱을 만들다 보면 데이터를 처리할 일이 많은데, 어느 타이밍에 데이터가 들어올지 확실히 알기가 어렵다.

스트림은 이와 같은 비동기 작업을 할 때 주로 쓰인다.

예를들어 네트워크에서 데이터를 받아서 UI에 보여주는 상황을 가정해본다면,
언제 네트워크에서 데이터를 다 받을지 알기 어렵다. 신호가 약한 와이파이를 쓸 수도 있고, 빵빵한 통신을 쓰고 있을 수도 있기 때문이다.

이런 문제를 스트림은 데이터를 만드는 곳과 소비하는 곳을 따로 둬서 이 문제를 해결할 수 있다.

Dart의 비동기 프로그래밍은 Future 및 Stream 클래스로 주로 처리하는데 이 둘의 차이점을 살펴보면

Future는 즉시 완료되지 않는 계산을 나타낸다. 일반 함수가 결과를 반환하는 경우 비동기 함수는 Future를 반환하며 결과에 포함된다. 결과가 준비되면 Future에 알려주는 것이다.

->future은 서버에 데이터를 요청 한 후 수신한 결과값에 대해서 then()으로 전달

->Stream은 구독자패턴(또는 관찰자 패턴)이다. 구독자(listen)가 관찰 대상(stream)을 구독하여 관찰 대상에 변화가 발생하면 구독자에게 그 변화를 알려준다.

🔎단일 구독 스트림(Single subscription streams)

가장 일반적인 종류의 스트림에는 더 큰 전체의 일부인 일련의 이벤트가 포함된다.
이벤트는 올바른 순서로 누락 없이 전달되어야 한다.

파일을 읽거나 웹 요청을 받을 때 얻는 스트림. 이러한 스트림은 한 번만들을 수 있다.

나중에 다시 듣는 것은 초기 이벤트가 누락되었음을 의미할 수 있으며 나머지 스트림은 의미가 없다.
청취를 시작하면 데이터가 페치 되어 청크로 제공된다.

🔎방송 스트림(Broadcast streams)

한 번에 하나씩 처리할 수 있는 개별 메시지를 위한 것.

이러한 종류의 스트림은 예를 들어 브라우저에서 마우스 이벤트에 사용될 수 있다.
언제든지 이러한 스트림 청취를 시작할 수 있으며 청취하는 동안 발생하는 이벤트가 발생한다.
둘 이상의 리스너가 동시에 들을 수 있으며, 이전 구독을 취소한 후 나중에 다시들을 수 있습니다.

스트림은 일련의 비동기 이벤트
요청 시 다음 이벤트를 받는 대신 스트림이 준비되면 이벤트가 있음을 알려주는 비동기 Iterable과 같다.

🔎코드로 살펴보기

리스너를 하나만 선언하는 경우

import ‘dart:async’;//패키지를 불러오기

void main() {
final controller = StreamController(); 
final stream = controller.stream // stream가져오기

final streamListener1 = stream.listen((val){
print(‘Listener1 : $val’); //Listener 1:1 … 5 까지 출력
//값을 듣고 있다가 들어오면 이 함수가 실행된다
});
controller.sink.add(1); //값을 전달
controller.sink.add(2); //여러개의 값을 전달할 수 있다
controller.sink.add(3);
controller.sink.add(4);
controller.sink.add(5);
}

리스너를 여러개 선언하는 경우-리소스가 허용하는 한 계속 선언할 수 있다

import ‘dart:async’;
void main() {
final controller = StreamController(); 
final stream = controller.stream 

final streamListener1 = stream.listen((val){
print(‘Listener1 : $val’); 
});
final streamListener2 = stream.listen((val){
print(‘Listener 2 : $val’);
});

controller.sink.add(1); 
controller.sink.add(2); 
controller.sink.add(3);
controller.sink.add(4);
controller.sink.add(5);
}

이렇게 바로 실행하면 안됨

final stream = controller.stream  //기본적으로 리스너를 한번만 선언 할 수 있는 리소스가 생김

여러번 계속 리스닝을 하고 싶으면

final stream = controller.stream.asBroadcastStream();

이렇게 바꿔줘야함

import ‘dart:async’;
void main() {
final controller = StreamController(); 
final stream = controller.stream.asBroadcastStream();

final streamListener1 = stream.listen((val){
print(‘Listener1 : $val’); 
});
final streamListener2 = stream.listen((val){
print(‘Listener 2 : $val’);
});

controller.sink.add(1); 
controller.sink.add(2); 
controller.sink.add(3);
controller.sink.add(4);
controller.sink.add(5);
}

//출력값-번갈아가면서 값을 리스닝 한다는것을 알 수 있다
Listener 1 : 1
Listener 2 : 1
Listener 1 : 2
Listener 2 : 2
Listener 1 : 3
Listener 2 : 3
Listener 1 : 4
Listener 2 : 4
Listener 1 : 5
Listener 2 : 5

즉석에서 Stream값을 변경하는 법-functional programming의 대부분 함수들을 사용할 수 있다
streamListener1에서는 짝수만 프린트하고 ,streamListener2에서는 홀수만 프린트 하려면?

import ‘dart:async’;
void main() {
final controller = StreamController(); 
final stream = controller.stream.asBroadcastStream();

final streamListener1 = stream.where((val)=>val % 2 == 0).listen((val){
print(‘Listener1 : $val’); 
});
final streamListener2 = stream.where((val)=>val % 2 == 1).listen((val){
print(‘Listener 2 : $val’);
});

controller.sink.add(1); 
controller.sink.add(2); 
controller.sink.add(3);
controller.sink.add(4);
controller.sink.add(5);
}

//출력값
Listener 2 : 1
Listener 1 : 2
Listener 2 : 3
Listener 1 : 4
Listener 2 : 5

functional programming처럼 바로 데이터가 들어오는 순간에 변형을 주거나 데이터를 다룰 수 있다.
함수로 Stream을 제공하는 방법

import ‘dart:async’;
void main() {
calculate(1).listen((val){
 print(‘calculate(2) : $val ’);
}
Stream<int> calculate(int number)async*{
 for (int i =0; i < 5; i+++){ // looping을 하면서 calculate에 넣어준 첫번째 파라미터와 곱하기를 하여 계산된 값을 Looping을 할 때 마다 돌려줄것
yield i * number; //yield가 실행이 될때마다 calculate함수를 리스닝 하고 있는 리스너에 값을 뿌려줄 수 있다
}
}
//출력값
calculate(1) : 0
calculate(1) : 2
calculate(1) : 4
calculate(1) : 6
calculate(1) : 8

일반적인 Future와 관련된 async함수를 async*로 된 함수에서 사용할 수 있는 방법-await사용

import ‘dart:async’;
void main() {
calculate(2).listen((val){
 print(‘calculate(2) : $val ’);
}
Stream<int> calculate(int number)async*{
 for (int i =0; i < 5; i+++){ 
yield i * number; 

await Future.delayed(Duration(second: 1));
}
}
//값이 1초마다 계산되어 출력된다
calculate(1) : 0
calculate(1) : 2
calculate(1) : 4
calculate(1) : 6
calculate(1) : 8

📍참고자료

• https://www.inflearn.com/course/dart-%EC%96%B8%EC%96%B4-%EC%9E%85%EB%AC%B8/unit/107633?tab=curriculum