📌Flow

흐르다 / 어떤 일이 진행이되다 / 분위기를 타다 의미를 가진다.

우리는 그중에 "데이터의 일이 진행" 되는 과정인 Coroutine Flow를 알아보자

✅ Coroutine Flow

river flow in you - 이루마

"Coroutine Flow도 마찬가지로 당신(User) 에게 데이터가 흐른다...."

쉽게 말하면 Flow를 사용하여 데이터베이스에서 실시간 업데이트를 수신할 수 있습니다.

⛽️ 데이터베이스(DB)

클린 아키텍쳐로 앱을 만들시에 Data Layer부분에서 Repostiroy 를 생성하여 데이터들을 가져오게된다 . 밑에 그림을 보자

물(Data)이 필요할때마다 가져오는 방식

• UI -> ViewModel -> Data Layer(Repository) -> ViewModel -> UI
• 데이터가 필요할 때마다 일일이 요청하여 DB에서 데이터를 가져와야 한다.
  (suspend fun 으로 사용하여 간편하게 사용할 수 있다)

  

❗️ 하지만 이렇게 사용만한다면 최신 데이터를 실시간으로 받아올 수 없다.

물(Data)이 알아서 관찰해서 가져오는 방식

• 밑에 그림 처럼 사용된다면 데이터가 자동적으로 업데이트되서 Flow를 타고 내려오게 됩니다.
• 이러한 방식을 ❗️Reactive❗️ 라고 말합니다
• 왜냐하면 observer가 관찰 대상의 변화를 자동 대응(Reactive) 하기 때문입니다.
• 그리고 데이터를 한 방향으로 흐르게 하는것이 좋습니다. 오류할 발생이 적고
  때문입니다.

Reactive Programming

데이터가 변경 될 때 이벤트를 발생시켜 데이터를 계속해서 전달하는 방식

데이터를 여러 방향 방식

• 밑에 그림을 보시면 view에서 Auth 정보 /User favaortie / items에 대한 정보가 있습니다.
• 뷰에서 여러가지 정보를 여러 방향으로 가져올 경우 버그가 생길 수도 있습니다

  

데이터 단방향 방식

• 밑에 그림처럼 한 Repository에서 여러 Data들을 연결하는 기능을 구현하여 안정적으로 데이터를 받을 수 있습니다
• 사용자가 로그아웃 및 로그인을 하면 그에 맞는 관(data)을 제거하여 유동적으로 Data를 처리 할 수 있습니다.
  

🍎 Flow 생성하기

[Flow가 만들어지는 순서]

🍏Producer(생산자)

Flow에서 flow{} 블록 내부에서 emit() 통해 데이터를 생성합니다.

📍위치(DataReomteSource)

userMessageDataSource에서 수시로 앱에온 메세지를 확인한다면?!

• flow{} 블록을 선언한다
• newsApi 이용하여 데이터를 서버로 부터 받아온다
• emit(Producer) 가 데이터를 생성한다
• 5초(refreshIntervalMs) 마다 반복해서 가져온다

class UserMessagesDataSource(
    private val newsApi: NewsApi,
    private val refreshIntervalMs: Long = 5000
) {
    val latestNews: Flow<List<ArticleHeadline>> = flow {
        while(true) {
            val latestNews = newsApi.fetchLatestNews()
            emit(latestNews) 
            delay(refreshIntervalMs)
        }
    }
}

🍏Intermediary(중개자)

생산자가 데이터를 생성하면 중간 연산자는 데이터를 수정/가공/예외 처리한다.

📍위치(Repository)

• map (데이터를 변형한다)
• filter(데이터 필터링)
• onEach(모든 데이터마다 연산을 각각수행)

생산자(newsRemoteDataSource)에서 만든 (lateNews)데이터를 가져와서
favorite topics 필터해서 가져온다음 각각(onEach) 최신 뉴스

class NewsRepository(
    private val newsRemoteDataSource: NewsRemoteDataSource,
    private val userData: UserData
) {
    val favoriteLatestNews: Flow<List<ArticleHeadline>> =
        newsRemoteDataSource.latestNews
            .map { it -> it.filter { userData.isFavoriteTopic(it)}
            .catch{ e ->
            	log.d("Error Loading reserved event")
            }
        
}

🍏Consumer(소비자)

Collect를 이용해 전달된 데이터를 소비합니다.

📍위치(ViewModel)

• 뷰모델 Scope안에서 비동기 함수로 실행되어 새로운 데이터를 collect하여 가져옵니다

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

    init {
        viewModelScope.launch {
            newsRepository.favoriteLatestNews.collect { favoriteNews ->
            //
            }
        }
    }

여기까지는 기초적인 Flow에 대해서 살펴 보았고 다음편에는 Flow에 대한 다른 기능으로 살펴볼 것이다