about Flow feat(ColdFlow, HotFlow)

💡 ColdFlow , HotFlow의 차이점을 확인하고 요약해보자.

Flow

Flow 란?

코틀린 플로우는 suspend function을 보완하기 위해 나온 친구이다.

비동기 동작의 결과로 suspend function 이 하나의 결과물 던진다면,
플로우를 이용하여 여러 개의 결과를 원하는 형식으로 던질 수 있다.

특징

비동기이며 코루틴에서만 동작 가능한 것은 suspend function 과 동일하다.

다른 점은 함수 앞에 suspend 를 붙이지 않아도 된다.

Flow Builder 유형

• flowOf() 주어진 항목 집합에서 흐름을 생성하는 데 사용됩니다.

flowOf(4, 2, 5, 1, 7)
.collect {
    Log.d(TAG, it.toString())
}

• asFlow() Type을 Flow로 변환할 수 있도록 도와주는 확장 기능입니다.

(1..5).asFlow()
.collect {
    Log.d(TAG, it.toString())
}

• flow{} 이것이 Flow의 Hello World 예제에서 사용한 것입니다.

flow {
    (0..10).forEach {
        emit(it)
    }
}
.collect {
    Log.d(TAG, it.toString())
}

• channelFlow{} 이 빌더는 빌더 자체에서 제공하는 send를 사용하여 요소로 흐름을 생성합니다.

channelFlow {
    (0..10).forEach {
        send(it)
    }
}
.collect {
    Log.d(TAG, it.toString())
}

cold stream ( kotlin의 sequence )으로 동작하며 hot stream 은 지원하지 않는다.

그렇기에 데이터는 요청할 때마다 처음부터 새로 발행되며,

요청 전에는 선언만 있을 뿐 아무런 동작도 하지 않는다.

직접 취소할 수 있는 함수는 따로 제공하지 않는다.

https://developer.android.com/kotlin/flow?hl=ko

cold-flow-vs-hot-flow

ColdFlow

• Collector가 있을때만 데이터를 emit 할 수 있다.
• 데이터를 저장하지 않는다.
• 여러 Collector를 가질 수 없다.
• 1 : 1

# [SharedFlow]

하나의 소비자(Consumer)에게 값을 보냅니다.
생성된 이후에 누군가 소비하기 시작하면 데이터를 발행합니다.
예를 들어 상태가 변하지 않는 값을 읽을 때

데이터베이스를 읽거나 URL을 통해서 서버 값을 읽는 경우 Cold Stream으로 구현할 수 있습니다.

HotFlow

• Collector가 없어도 데이터를 emit 할 수 있다.
• 데이터를 저장 할 수 없다.
• 여러 Collector를 가질 수 있다.
• 1 : N

# [StateFlow]

하나 이상의 소비자(Consumer)에게 값을 보낼 수 있습니다.
데이터 발행이 시작된 이후 부터 모든 소비자에게 같은 데이터를 발행하고 구독자가 없는 경우에도 데이터를 발행합니다.
예를 들어 상태가 변하는 값을 읽을 때 네트워크 상태 정보 값을 얻어올 때 Hot Stream을 사용할 수 있습니다.