Flow (19장 정의)

• 비동기적으로 계산해야 할 값의 스트림
• Flow 인터페이스 자체는 떠다니는 원소들을 모으는 역할을 하며, 플로우의 끝에 도달할 때까지 각 값을 처리하는 걸 의미합니다. (Flow collector 는 forEach와 비슷합니다.)

• 플로우는 어떤 연산을 실행할지 정의한 것으로, 중단 가능한 람다식에 몇 가지 요소를 추가한 거라고 생각하면 됩니다.
• 람다식을 변환하여 Flow 인터페이스와 flow 빌더를 어떻게 구현하는지 단계별로 설명

Flow 이해하기

간단한 람다식부터 시작

fun main() {
    val f: () -> Unit = {
        print("A")
        print("B")
        print("C")
    }

    f()
    f()
}

// ABCABC

내부에 지연이 있는 람다식 suspend

suspend fun main() {
    val f: suspend () -> Unit = {
        print("A")
        delay(1000)
        print("B")
        delay(1000)
        print("C")
    }

    f()
    f()
}

// A(1초후)B(1초후)CA(1초후)B(1초후)C
// ABCABC

람다식은 함수를 나타내는 파라미터를 가질 수 있다 (emit)

suspend fun main() {

		// suspend () -> Unit
		// suspend ((String) -> Unit) -> Unit
		
    val f: suspend ((String) -> Unit) -> Unit = { emit ->
        emit("A")
        emit("B")
        emit("C")
    }

    f { print(it) }
    f { print(it) }
}

// ABCABC

위의 복잡한 함수형 코드를 emit이라는 추상 메서드를 가진 FlowCollector 함수형 인터페이스로 분리