[Kotlin] 코틀린 Coroutine에 대하여 (3) - Coroutine Flow(플로우)

안녕하세요👋

오늘은 코루틴 관련 마지막 포스팅으로

코루틴 Flow에 대해 공부한 내용을 포스팅해보려 합니다.

 

---

1. Coroutine Flow란?

Flow는 순차적으로 값을 내보내고 정상적으로 또는 예외로 완료되는 비동기적인 데이터 스트림입니다.

 

Flow에는 총 3가지 역할이 존재하며 각각의 설명은 아래와 같습니다.

Producer (생산자)

데이터 스트림(flow)을 생산하며 코루틴을 비동기적으로 생산 가능하게 해 줌

InterMediary(중개자)

Producer가 내보내는 각각의 값이나 스트림 자체를 수정, 삭제,병합 등의 조작 작 업을 수행

consumer(소비자 , 구독자)

스트림을 소비하는 곳( Android에서는 주로 UI 작업)

 

---

2. Cold Flow와 Hot Flow

Cold Flow는 소비자(구독자)마다 개별 Flow 생성이 시작되어 데이터를 전달하며 Flow 생성 후 소비(collect {...})를(collect{...}) 하지 않으면 어떤 연산도 발생하지 않습니다. (즉, 소비하지 않으면 어떤 연산도 발생하지 않는다.) 

반면, Hot Flow는 Flow가 생성되면 바로 연산이 시작되고 데이터를 전달하며 다수의 소비자가 동일 한 Flow에서 데이터를 전달받을 수 있습니다. 

✔️ Flow에서 중간연산자(중개자)를 지정하지 않는다면 Flow는 Cold 해집니다. (중간 연산자가 실행될 때마다 Producer 코드가 실행되기 때문)

 

 

그렇다면 Flow는 어떻게 사용할까요?? 🤔

 

기본적으로 생산자에서 데이터의 흐름을 방출 ( emit() )하고 소비자에서 그 흐름을 모아서 소비( collect() )합니다.

아래 간단한 예제를 통해 설명 드리겠습니다.

 

import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.runBlocking

fun coroutineFlowAction(): Flow<Int> { return flow {
    (1..5).forEach { delay(1000)
        /**
         * 호출한 쪽(소비자,구독자)에 데이터를 방출한다 */
        emit(it)
    } }
}
fun main() = runBlocking {
// 흐름을 모은다(collect) 
 coroutineFlowAction().filter {
    it % 2 != 0 }.collect{
    println(it) }
}

 

위 예제는 소수를 구하는 간단한 예제로 Flow <T> 객체를 반환하는 coroutineFlowAction() 함수 내부에서 flow builder를 통해

flow를 생성해주었습니다. 이후 main 함수에서 해당 Flow객체 중 소수만을 filter 하여 소비( collect() )하여 출력해주도록 하였습니다.

 

소수만 출력된 화면

 

Flow의 흐름 이해도

 이미지 참조 : https://myungpyo.medium.com/

 

위 이미지는 해당 포스팅에서 참조하였으며 Flow의 흐름에 대해 이해하기 쉽게 설명되어 있어 참고 자료로 첨부하였습니다.

---

3. Flow의 중간 함수

중간 함수를 통해 Flow에서 emit()한 값들을 전달받아 원하는 데이터로 변경하여 바로 얻을 수 있습니다.

 

map()

인바운드된 데이터를 업스트림(map)을 통해 결과(다운스트림)와 매핑하는 함수

import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.asFlow
import kotlinx.coroutines.flow.map
import kotlinx.coroutines.flow.take
import kotlinx.coroutines.runBlocking

suspend fun flowRequest(inputValue: Int): String { delay(1000)
    return "응답 : $inputValue" }
fun main() {
    runBlocking {
        (1..5).asFlow() //Flow 생성
            .take(3).map(::flowRequest).collect(::println)
    }
}

 

위 예제는 1~5까지 수를 Flow로 발행하여 3회 동안 map함수를 거쳐 반환된 값을 print 하는 프로그램입니다.

위와 같이 map함수를 통해 매핑할 동작을 정의해주면 Flow를 통해 전달된 값을 자동으로 매핑하여 반환해줍니다.

 

map 실행 결과

 

transform()

단순 변형(map,보다는 복잡한 변형에 적합

import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.asFlow
import kotlinx.coroutines.flow.transform
import kotlinx.coroutines.runBlocking

fun main() {
    runBlocking { (1..10).asFlow()
    .transform { delay(1000)
        if (it % 2 != 0) { emit(it)
            emit(it * it)
            emit(it * it * it) }
    }
    .collect { println(it) } }
}

 

위 예제는 1~10까지의 값을 Flow로 발행하여 transform을 통해 collect()할 때 제곱과 3 제곱을 함께 반환하도록 하는 프로그램입니다. 결론적으로는 map과 동일하게 값을 변경하여 반환해주지만,

map()보다는 조금 더 복잡한 연산을 할 때 주로 사용한다고 보면 될 것 같습니다.

 

transform 실행 결과

 

---

이 외에도 많은 중간 함수들이 존재하며 상황에 따라 사용해준다면 강력한 도구가 될 것 같습니다.

 

이상으로 코루틴 Flow에 관한 포스팅을 마치겠습니다. 👋

 

오늘도 즐코 하세요 :)