Flow Cold Stream(콜드 스트림), Hot Stream(핫 스트림)

💡목표

• Cold Stream, Hot Stream을 이해한다.

📝 정리하기

Cold Stream

• 하나의 소비자에게 값을 보냄
• 생성된 이후에 누군가 소비하기 시작하면 데이터 발행
• 상태가 변하지 않는 값을 읽을 때 데이터 베이스를 읽거나 URL을 통해서 서버값을 읽는 경우 구현

1. flow 생성: flow 빌더를 사용하여 콜드 스트림을 생성. 이때 데이터 항목을 emit 으로 방출 → 스트림이 시작될 때 로그 출력
2. 구독 전 상태: 스트림이 생성되었지만 아직 수집자가 없으므로 아무런 작업도 수행 x
3. 구독: 첫 번째 구독자는 launch를 사용하여 코루틴을 시작하고, coldFlow.collect를 호출하여 스트림을 구독 이때 스트림은 데이터를 방출하기 시작
4. 두 번째 구독자: 두 번째 구독자는 3초 후에 스트림을 구독하기 시작. 이 구독자는 구독 시점부터 데이터를 수집
5. joinAll 사용: 모든 코루틴 작업이 완료될 때까지 joinAll을 사용하여 대기

⇒ 각 구독자가 스트림에서 데이터를 수집하는 과정을 통해 콜드 스트림의 특성을 보여줌. 콜드 스트림은 구독자가 생길 때마다 새로 시작되며, 각 구독자는 처음부터 데이터를 수집

 

Hot Stream

• 하나 이상의 소비자에게 값을 보냄
• 데이터 발행이 시작 된 이후부터 모든 소비자에게 같은 데이터를 발행하고 구독자가 없는 경우에 데이터 발행
• 상태가 변하는 값을 읽을 때 네트워크 상태 정보 값을 얻어올 때 사용할 수 있음

 

1. MutableSharedFlow 생성: MutableSharedFlow를 사용하여 핫 스트림을 생성
2. 데이터 방출:  launch를 사용하여 코루틴을 시작하고, repeat와 delay를 사용하여 1초마다 데이터를 방출. sharedFlow.emit으로 데이터를 스트림에 방출
3. 첫 번째 구독자: 첫 번째 구독자는 애플리케이션이 시작되자마자 스트림을 구독 sharedFlow.collect를 호출하여 데이터를 수집
4. 두 번째 구독자: 두 번째 구독자는 5초 후에 스트림을 구독하기 시작. 이 구독자는 구독 시점부터 방출되는 데이터를 수집
5. joinAll 사용: 모든 코루틴 작업이 완료될 때까지 joinAll 을 사용하여 대기

⇒ 각 구독자가 스트림에서 데이터를 수집하는 과정을 통해 핫 스트림의 특성을 보여줌

 

git repository

 https://github.com/mygomii/mygomii-study/tree/main/stream