Combining flows (zip, combine) in Kotlin - Step-by-Step Execution

Concept Flow - Combining flows (zip, combine)

Start Flow A

↓

Emit value A1

↓

zip/combine

↓

Emit combined value

↓

Wait for next emissions

↓

Emit value A2

↓

zip/combine

↓

Emit combined value

↓

End

Two flows emit values independently. zip waits for both to emit once, then combines pairs. combine emits on any new value, combining latest from both.

Execution Sample

Kotlin

val flowA = flowOf(1, 2)
val flowB = flowOf("A", "B")

flowA.zip(flowB) { a, b -> "$a$b" }
    .collect { println(it) }

This code zips two flows, pairing each number with a letter, then prints combined strings.

Execution Table

Step	FlowA Emission	FlowB Emission	zip/combine Action	Output
1	1	A	zip pairs 1 and A	"1A"
2	2	B	zip pairs 2 and B	"2B"
3	-	-	No more emissions, flow ends	-

💡 Both flows completed, no more pairs to zip

Variable Tracker

Variable	Start	After 1	After 2	Final
flowA value	-	1	2	-
flowB value	-	A	B	-
combined output	-	"1A"	"2B"	-

Key Moments - 3 Insights

Why does zip wait for both flows to emit before producing output?

zip pairs values one-to-one, so it waits for a new value from each flow before combining, as shown in execution_table rows 1 and 2.

What happens if one flow emits more values than the other?

zip stops when the shorter flow ends, so extra values from the longer flow are ignored, as seen in exit_note.

How is combine different from zip in combining flows?

combine emits whenever any flow emits, using the latest values from both, unlike zip which waits for pairs, explained in concept_flow.

Visual Quiz - 3 Questions

Look at the execution_table, what is the output at Step 2?

A "2B"

B "1B"

C "2A"

D "1A"

💡 Hint

Check the Output column at Step 2 in execution_table

At which step does zip stop emitting values?

A Step 2

B Step 3

C Step 1

D Never stops

💡 Hint

Look at exit_note and Step 3 in execution_table

If flowB emitted an extra value "C", how would zip behave?

A Emit a third combined value with flowA's last value

B Crash with error

C Ignore the extra value and stop after pairs are done

D Repeat the last combined value

💡 Hint

Refer to key_moments about zip stopping when shorter flow ends

Concept Snapshot

zip pairs values from two flows one-to-one, emitting combined pairs.
combine emits on any new value, combining latest from both flows.
zip stops when one flow ends; combine continues with latest values.
Use zip for strict pairing, combine for latest-value updates.
Syntax: flowA.zip(flowB) { a,b -> ... } or flowA.combine(flowB) { a,b -> ... }

Full Transcript

This visual trace shows how Kotlin flows can be combined using zip and combine. Two flows emit values independently. zip waits for both flows to emit a value, then pairs them one-to-one, emitting combined results. The execution table shows step-by-step emissions from flowA and flowB, the zip action pairing values, and the output produced. zip stops when the shorter flow ends, ignoring extra values from the longer flow. combine differs by emitting whenever any flow emits, using the latest values from both. The variable tracker shows how values change after each emission. Key moments clarify why zip waits for both flows and what happens if flows have different lengths. The quiz tests understanding of output at steps, when zip stops, and behavior with extra values. The snapshot summarizes syntax and behavior for quick reference.