여러 개의 flow을 combine으로 처리하기

Combine으로 여러 flow 처리하기

리사이클러뷰에 보여줄 아이템은 여러 api 응답값을 조합해서 만들어야한다.

좋아요 상태 값을 likeRepository의 checkLike함수로 부터 받고 emit 해주는 flow를 작성해준 후 이를 뷰모델에서 처리해주려고 하였다.!!

class GetLikeStateUseCase @Inject constructor(private val likeRepository: LikeRepository) {
    operator fun invoke(reportId: String): Flow<Boolean> =
        flow {
            val result = likeRepository.checkLike(reportId = reportId)
            emit(result.getOrNull() ?: false)
        }.catch {
            Timber.e(it)
        }
}

결과

따란~

🙂‍↔️문제 발생

그런데 문제가 발생하였다. 좋아요 상태를 알기 위해서는 게시글의 아이디를 넘겨줘야하는데 이걸 어떻게 넘겨줘야할까... 

 

우선 현재와 같이 동시에 combine 해줄 수 없게 되었다.

어떡하지 어떡하지

공식문서를 본 후 저장소 결합 방식에 대해 알게 되었다. 이를 사용해서 여러 개의 usecase로 나누지 않고 하나의 usecase에서 처리해주도록 변경하면 어떨까?

왜냐하면 좋아요 상태를 가져오기 위해서는 감상문의 id값이 필요하기 때문이다!

 

참고한 저장소 결합 코드

/**
 * This use case fetches the latest news and the associated author.
 */
class GetLatestNewsWithAuthorsUseCase(
  private val newsRepository: NewsRepository,
  private val authorsRepository: AuthorsRepository,
  private val defaultDispatcher: CoroutineDispatcher = Dispatchers.Default
) {
    suspend operator fun invoke(): List<ArticleWithAuthor> =
        withContext(defaultDispatcher) {
            val news = newsRepository.fetchLatestNews()
            val result: MutableList<ArticleWithAuthor> = mutableListOf()
            // This is not parallelized, the use case is linearly slow.
            for (article in news) {
                // The repository exposes suspend functions
                val author = authorsRepository.getAuthor(article.authorId)
                result.add(ArticleWithAuthor(article, author))
            }
            result
        }
}