🤔 Flow in Coroutine

코루틴에서 플로우는 데이터 스트림이며 코루틴 상에서 리액티브 프로그래밍을 지원 하기 위한 구성 요소다. 플로우는 suspend function을 사용하여 값을 비동기적으로 생성하고 사용한다. 즉 기본 스레드를 차단하지 않고 네트워크 요청이 가능하다.

1. Producer

   생산자는 DataSource로부터 데이터를 가져와 스트림에 데이터를 발행한다. flow 블록 안에서 emit 함수를 사용하여 데이터를 내보낸다.

   class KakaoRemoteDataSource @Inject constructor(
       private val kakaoService: KakaoService
   ) : KakaoDataSource {
       override fun getKeywordPlace(
           keyword: String
       ): Flow<PlaceKeywordResult> = flow{
   		emit(kakaoService.getKeywordPlace(keyword))
   	}
   }
   

   아래 예에서는 데이터 소스가 고정된 간격으로 최신 뉴스를 가져 온다.

   class NewsRemoteDataSource(
       private val newsApi: NewsApi,
       private val refreshIntervalMs: Long = 5000
   ) {
       val latestNews: Flow<List<ArticleHeadline>> = flow {
           while(true) {
               val latestNews = newsApi.fetchLatestNews()
               emit(latestNews) // Emits the result of the request to the flow
               delay(refreshIntervalMs) // Suspends the coroutine for some time
           }
       }
   }
   

2. Intermediary

   중개자는 스트림에 내보내는 각각의 값이나 스트림 자체를 수정할 수 있다. 예를 들어 서버로 부터 받은 데이터나 데이터의 자료형이 view에서 필요하도록 바꾸는 작업이 이에 해당한다. 중간 연산자에는 **map(데이터 변형), filter(데이터 필터링), onEach(모든 데이터 마다 연산 수행)**이 있다.

   class KakaoRepositoryImpl @Inject constructor(
       private val kakaoRemoteDataSource: KakaoRemoteDataSource,
   ): KakaoRepository {
       override fun getKeywordPlace(
           keyword: String
       ): Flow<List<Place>> = kakaoRemoteDataSource.getKeywordPlace(keyword).map{
           it.documents.map{p->Place(p.place_name, p.category_name, p.x, p.y)}
       }
   }
   

3. Consumer

   소비자는 collect를 이용하여 스트림의 값을 사용한다. collect는 suspend function이므로 코루틴 내에서 실행되어야 한다.

   class LatestNewsViewModel(
       private val newsRepository: NewsRepository
   ) : ViewModel() {
   
       init {
           viewModelScope.launch {
               // Trigger the flow and consume its elements using collect
               newsRepository.favoriteLatestNews.collect { favoriteNews ->
                   // Update View with the latest favorite news
               }
           }
       }
   }
   

예외 처리

catch 블록을 사용하여 예외를 처리할 수 있다.

class LatestNewsViewModel(
    private val newsRepository: NewsRepository
) : ViewModel() {

    init {
        viewModelScope.launch {
            newsRepository.favoriteLatestNews
                // Intermediate catch operator. If an exception is thrown,
                // catch and update the UI
                .catch { exception -> notifyError(exception) }
                .collect { favoriteNews ->
                    // Update View with the latest favorite news
                }
        }
    }
}

flowOn

withContext와 비슷하게 수행하는 context를 바꿀 수 있다. 그러나 코루틴에서 emit을 하는 context와 collect하는 context는 같아야 한다. 이런 경우 flowOn을 사용하여 emit하는 부분의 context를 바꿀 수 있다. flowOn 연산자는 flowOn 위에 부분(upstream)만 영향을 받는다.

class NewsRemoteDataSource(
    ...,
    private val ioDispatcher: CoroutineDispatcher
) {
    val latestNews: Flow<List<ArticleHeadline>> = flow {
        // Executes on the IO dispatcher
        ...
    }
        .flowOn(ioDispatcher)
}

데이터 소스 레이어가 I/O 작업을 수행하므로 I/O 작업에 최적화된 디스패쳐를 사용해야 한다.

😋 StateFlow

Flow의 한계 및 LiveData 문제점

하지만 Flow는 데이터의 흐름을 발생시키기만 할뿐 데이터를 저장하지 않는다. 즉 화면이 재구성될 때마다 서버나 로컬 DB로부터 데이터를 받아오거나 데이터 값이 collect 될때마다 ViewModel에 저장해놓고 사용해야한다. 전자는 매우 비효율적인 방법이므로 사용하지 않는다.

기존에는 LiveData를 사용하여 서버로 부터 데이터를 받아왔다. LiveData는 옵저버 패턴을 활용하여 구현되었고 생명주기의 변화를 자체적으로 인식한다는 장점이 있다.

하지만 Clean Architecture를 도입하면서 Domain Layer에서도 그대로 LiveData를 적용하는 경우가 있는데 이는 맞지 않다. 도메인 계층은 안드로이드에 의존성을 가지지 않는 순수 코틀린 코드로 작성되어야 한다. 그러나 LiveData는 UI와 매우 밀접하게 연결되어 있고 안드로이드 플랫폼에 속해있기 때문에 도메인 레이어에서 사용하기에 적합하지 않다.

StateFlow 등장