[Android] Flow란?

🤔 Flow란?

flow는 직역하면 흐름입니다.
android에서는 값을 순차적으로 보낼 수 있는 data Stream입니다.
flow는 데이터를 생성하고 처리하는 작업을 *비동기적으로 수행합니다.

* 비동기 : 비동기 작업은 여러 작업을 동시에 할 수 있습니다. 한 작업이 완료되기를 기다리지 않고, 다음 작업을 즉시 시작할 수 있습니다.

그림은 (값을 순차적으로 내보내는 과정으로) 생산자는 데이터를 생산하고 flow를 통해 중개자는 데이터를 가공할 수 있습니다.
그리고 소비자가 구독을 하면 데이터를 소비할 수 있는 구조입니다.

일단 flow의 동작방식을 구현해보고 flow에 대해서 더 이야기 해보겠습니다.

💻 Flow 예제

flow는 flow 빌더 API를 사용해 만들고, emit()을 이용해 값을 수동으로 데이터 스트림으로 보냅니다.

1. 생산자

flow 빌더를 통해 TestFlow를 만들었습니다.

val TestFlow: Flow<Int> = flow {
    for (i in 1..10) {
        delay(1000)
        emit(i)
    }
}

2. 중개자

flow는 다양한 연산자를 지원하며 map, filter, reduce, transform 등의 연산자로 데이터를 변환할 수 있습니다

TestFlow
    .map { it * 2 }  // 각 값에 2를 곱함
    .filter { it % 2 == 0 }  // 짝수만 통과

3. 소비자

flow는 비동기 방식을 이용하므로 Coroutine을 사용해야 합니다.
소비자는 collect를 통해 flow에서 값을 수집하고 데이터를 호출합니다.

launch {
    TestFlow.collect { value ->
        println(value)
    }
}

📌 flow 더 들여다보기

flow는 Cold Stream의 특성을 가집니다.
Cold Stream은 구독이 시작될 때 데이터를 생성하는 것을 말합니다.
Cold Stream은 가장 최신의 데이터 부터 방출하기에 이전에 방출되었던 데이터는 유지하지 않습니다.

👁‍🗨 예를 들어보겠습니다.

집에서 물을 마시고 싶다고 했을 때,
생산자는 물탱크 있는 물을 생산합니다. (이때 원래 비어있는 물탱크라고 가정하겠습니다.)
이때 정수기로 물을 온수로 할지, 냉수로 할지, 얼음으로 할지 변경이 가능합니다. 이는 중개자의 역할을 합니다.
마지막으로 사람이 원하는 물을 소비( collect=구독 ) 하여 물을 마실 수 있습니다.
이때 flow는 물(data)을 감싸고 있는 배관(데이터 스트림)이 됩니다.

flow는 비동기 방식으로 작업을 수행하기에 대용량 데이터나 네트워크 요청 등의 시간이 오래걸리는 작업에 UI 스레드를 차단하지 않고 처리가 가능합니다.
또 다양한 연산자를 제공하기에 복잡한 데이터 처리 로직을 간편하게 구현할 수 있습니다.

😥 flow 단점?

flow는 Cold Stream 특성으로 구독이 시작될 때만 데이터를 생성하므로 원하는 시점의 데이터를 캐시하거나 재사용하는 것이 어려울 수 있습니다.
또 비동기식으로 작업을 수행하므로 복잡한 데이터 흐름이나 오류 상황에서의 디버깅이 어려울 수 있습니다.

😊 마치며

이번 시간에 flow에 대해 알아보았습니다
다음 시간엔 flow의 단점을 보완할 방법에 대해 알아보겠습니다.