Android의 Kotlin 코루틴 - 2(Flow)

김재원·2022년 1월 11일

코루틴

목록 보기

2/3

이전글에서는 코루틴이 무엇인가에 대해서 알아보았었습니다. 그리고 이글에서는 flow란 무엇인가에 대해서 알아보겠습니다.

ReacticeX를 먼저 익히고 coroutine을 공부한 저로써는 flow를 이해하기 정말 쉬웠습니다😏. flow는 ReacticeX에서의 Observable과 똑같았는데요, Observable 에서 처럼 map 함수도 쓸 수 있고, zip도 있는 등, 이해하기 정말 쉬웠습니다.

그래서 flow가 뭔데?

서론에서는 혹시 저처럼 RxJava를 먼저 공부하셨던 분이 계시면 저 문구가 flow를 이해하는데에 도움이 될것 같아서 ReactiveX와 연관시켜보았습니다😌.
coroutine에서 suspend함수는 단일값만 출력합니다. 하지만 리엑티브(반응형) 프로그램을 개발하다보면 데이터를 순차적으로 받아야할 경우가 있죠. 이럴때 flow를 통해서 데이터를 받는것입니다.
즉, 데이터의 흐름을 만드는것인데요. 데이터 흐름은 다음과 같이 만들어 집니다.
위 그림은 왼쪽부터 소비자, 중개자, 생산자를 표현한 그림입니다.

생산자는 데이터를 생산합니다. Android 개발 관점에서 보면 서버와의 통신을 통해 데이터를 가져온것 정도로 생각할 수 있겠습니다. 데이터가 만들어진것이죠.
중개자는 데이터를 가공, 수정합니다. 생산자가 만든 데이터를 필요에 맞게 변경하는것이죠. map함수등을 사용할 수 있습니다.
소비자는 데이터를 사용합니다. 마지막에 데이터를 사용하는 viewModel 혹은, view등이 될 수 있습니다.

Flow 생성하기(생산자)

flow는 FlowBuilder를 통해 만들 수 있습니다🙂.

class Datasource {
   suspend fun fetchData(): Flow<String> {
      return flow { // flowBuilder
        for(value in 0..3) {
           delay(1000)
           emit(value.toString()) //데이터 방출(생산)
        }
      }
    }
}

fetchData()는 0부터 3까지의 데이터를 1초간격으로 생산하는 함수입니다. flow빌더를 통해 흐름을 만들고, emit함수를 통해 데이터를 생산하였죠😏.

주의해야할 점

흐름은 순차적입니다. 그래서 flow 안에서 suspend 함수를 호출했다면 suspend함수가 반환될 때 까지 정지합니다.

val dataSource = flow{
   for(count in 0..3){
     val result = fetchData() // fetchData가 return 된 후 다음 코드가 실행됩니다.
     emit(result+" return")
   }
}

suspend fun fetchData(): String {
    delay(1000)
    return "data"
}