Kotlin Academy · 강의

combine과 zip: 여러 Flow 병합하기

여러 Flow를 결합하고 방출 값을 함께 zip해 보세요.

combine과 zip: 여러 Flow 병합하기은(는) CoddyKit의 무료 Kotlin Academy 강의입니다. 이것은 4개 중 3번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Kotlin Academy 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Kotlin Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

플로우를 병합하는 이유

실제 앱에서는 여러 데이터 스트림을 결합해야 하는 경우가 많습니다. 예를 들어 사용자 환경 설정과 네트워크 데이터, 양식 필드와 유효성 검사 상태를 결합할 수 있습니다. 코틀린 플로우는 이를 위해 zip, combine, merge를 제공합니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val names = flowOf("Alice", "Bob", "Carol")
    val ages  = flowOf(30, 25, 35)
    names.zip(ages) { name, age -> "$name is $age" }
         .collect { println(it) }
}

zip: 쌍으로 방출되는 값

zip은 방출되는 값을 순서대로 일대일로 짝짓습니다. 더 짧은 플로우가 끝나면 중지됩니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val a = flowOf(1, 2, 3, 4)   // 4 elements
    val b = flowOf("a", "b", "c")  // 3 elements — zip stops here
    a.zip(b) { n, s -> "$n-$s" }
     .collect { println(it) } // 1-a, 2-b, 3-c
}

결합: 최신 값

combine은 플로우 중 하나라도 값을 방출할 때마다 각 플로우의 최신 값을 사용해 새 값을 방출합니다. 두 플로우 모두 최소 한 번은 값을 방출해야 합니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val flow1 = MutableStateFlow(1)
    val flow2 = MutableStateFlow("a")
    combine(flow1, flow2) { n, s -> "$n-$s" }
        .take(1)
        .collect { println(it) } // 1-a
}

결합과 zip의 차이

zip: 일치하는 쌍을 기다립니다. combine: 최신 값을 사용해 업데이트가 발생할 때마다 실행됩니다. 반응형 UI(예: 두 양식 필드)에는 결합을 사용하고, 순차적인 짝짓기에는 zip을 사용하십시오.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    // zip: 1-a, 2-b
    val nums = flowOf(1, 2).zip(flowOf("a", "b")) { n, s -> "$n-$s" }
    nums.collect { println("zip: $it") }

    // combine fires more:
    combine(flowOf(1, 2), flowOf("a")) { n, s -> "$n-$s" }
        .collect { println("combine: $it") }
}

병합: 플로우를 끼워 넣기

merge는 여러 플로우에서 값이 도착하는 즉시 짝짓기 없이 방출합니다. 출력 순서는 값이 방출되는 시점에 따라 달라집니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val a = flow { emit("A1"); delay(50); emit("A2") }
    val b = flow { delay(25); emit("B1") }
    merge(a, b).collect { println(it) } // A1, B1, A2
}

플로우 3개 이상 결합하기

combine은 여러 플로우를 지원합니다. 플로우를 가변 인자로 전달하면 람다가 모든 최신 값을 받습니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val a = MutableStateFlow("hello")
    val b = MutableStateFlow(42)
    val c = MutableStateFlow(true)
    combine(a, b, c) { s, n, flag -> "$s-$n-$flag" }
        .take(1)
        .collect { println(it) } // hello-42-true
}

flatMapMerge: 내부 플로우를 동시에 처리하기

flatMapMerge는 각 요소를 플로우로 매핑한 다음 모든 내부 플로우를 동시에 수집하여 출력을 병합합니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    (1..3).asFlow()
        .flatMapMerge { n ->
            flow { delay(100L - n * 10); emit("result-$n") }
        }
        .collect { println(it) }
}

flatMapLatest: 새 값이 방출되면 취소하기

flatMapLatest는 상류에서 새 요소가 도착하면 현재 내부 플로우를 취소합니다. 입력하는 즉시 검색하는 기능에 적합합니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    flowOf("k", "ko", "kot", "kotl", "kotli", "kotlin")
        .flatMapLatest { query ->
            flow {
                delay(50)  // simulate debounced search
                emit("Result for: $query")
            }
        }
        .collect { println(it) } // only "Result for: kotlin"
}

트랜잭션 짝짓기에 zip 사용하기

두 스트림의 이벤트를 짝지을 때 zip을 사용하십시오. 예를 들어 사용자 동작과 서버 확인 응답을 짝지어 일대일 대응을 보장할 수 있습니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val orders = flowOf("Order1", "Order2", "Order3")
    val confirmations = flowOf("Confirmed", "Confirmed", "Rejected")
    orders.zip(confirmations) { order, status -> "$order: $status" }
          .collect { println(it) }
}

양식 유효성 검사에 결합 사용하기

사용자 이름 플로우와 비밀번호 플로우를 결합하여 양식의 유효성을 반응형으로 계산하십시오. 어느 필드가 변경되든 업데이트됩니다.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun main() = runBlocking {
    val username = MutableStateFlow("")
    val password = MutableStateFlow("")
    val isValid = combine(username, password) { u, p ->
        u.length >= 3 && p.length >= 8
    }
    username.value = "alice"
    password.value = "secure123"
    println(isValid.first()) // true
}

onEach + 결합으로 여러 출처의 로딩 처리하기

로딩 플래그와 데이터 플로우를 결합하여 서로 독립적인 여러 출처로부터 하나의 UI 상태 객체를 만드십시오.

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
data class UI(val loading: Boolean, val data: String)
fun main() = runBlocking {
    val loading = MutableStateFlow(true)
    val data    = MutableStateFlow("")
    combine(loading, data) { l, d -> UI(l, d) }
        .take(2)
        .collect { println(it) }
    data.value = "result"
    loading.value = false
}

빠른 확인

zip과 combine의 핵심적인 차이점은 무엇입니까?

복습

zip은 방출되는 값을 순차적으로 짝짓고, 결합은 최신 값을 사용해 어떤 업데이트에도 실행되며, 병합은 독립적인 플로우를 끼워 넣고, flatMapLatest는 오래된 내부 플로우를 취소합니다. 짝짓기가 필요한지 반응성이 필요한지에 따라 선택하십시오.

자주 묻는 질문

“combine과 zip: 여러 Flow 병합하기” 강의는 무료인가요?

네 — “combine과 zip: 여러 Flow 병합하기” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Kotlin Academy 강의 전체를 잠금 해제할 수 있습니다. Kotlin Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

“combine과 zip: 여러 Flow 병합하기”에서 뭘 배우나요?

여러 Flow를 결합하고 방출 값을 함께 zip해 보세요. 브라우저에서 직접 실행하는 실습 코드로 Kotlin Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

Kotlin Academy을(를) 시작하는 데 경험이 필요한가요?

사전 경험은 필요하지 않습니다. CoddyKit의 Kotlin Academy은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 3번째 강의입니다.

“combine과 zip: 여러 Flow 병합하기” 강의는 얼마나 걸리나요?

대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.

이 Kotlin Academy 강의에서 코드를 작성하고 실행할 수 있나요?

네. 모든 Kotlin Academy 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.

이 강의의 모든 강의

← Kotlin Academy(으)로 돌아가기