coroutines-flow

What problem does it solve?

Flow-based programming patterns solve the challenge of modeling asynchronous streams in Kotlin, providing a principled way to build composable, cancellation-friendly pipelines.

Core Features & Use Cases

• Learn to construct Flow pipelines with flow { }, callbackFlow, and channelFlow to handle producers and consumers.
• Use common operators such as map, filter, debounce, transform, flatMapMerge, and flowOn, along with lifecycle hooks like onStart, onEach, onCompletion, and catch/retry.
• Compare Flow and Sequence, reason about backpressure, cancellation, testing with runTest and turbine, and practical streaming scenarios (debounced streams, data processing, and I/O-bound pipelines).

Quick Start

Try a simple Flow example by creating a flow { emit(1); emit(2) } and collecting it to observe the emitted values.