플로우 버퍼링

buffer

buffer로 버퍼를 추가해 보내는 측이 더 이상 기다리지 않게 한다.

 

 

---

conflate

conflate를 이용하면 중간의 값을 융합(conflate)할 수 있다. 처리보다 빨리 발생한 데이터의 중간 값들을 누락한다.

즉, 내가 처리하지 못하고 있던 사이에 받았던 중간 값들을 버리는 것이다.

 

 

---

collectLatest

conflate와같이 방출되는 값을 누락할 수도 있지만 수집 측이 느릴 경우 새로운 데이터가 있을 때 수집 측을 종료시키고 새로 시작한다.

-> 마지막 값만 처리한다.

 

 

 

 

 

 

 

본 글은 The RED : 효과적인 비동기처리를 위한 Kotlin Coroutines & Flow 마스터 by 김용욱 강의를 듣고 정리한 글입니다.