[ 코틀린 코루틴 - 24장 ] 공유플로우와 상태플로우

핵심 개념Flow는 콜드 스트림으로 각 구독자마다 독립적으로 실행되지만, SharedFlow와 StateFlow는 핫 스트림으로 여러 구독자가 하나의 데이터 소스를 공유합니다. SharedFlow여러 구독자가 동시에 같은 데이터를 받아야 할 때 사용합니다. 기본 사용법val sharedFlow = MutableSharedFlow()// 여러 구독자가 동시에 수신launch { sharedFlow.collect { println("구독자1: $it") } }launch { sharedFlow.collect { println("구독자2: $it") } }sharedFlow.emit("메시지") // 모든 구독자가 받음 replay 파라미터val sharedFlow = MutableSharedFlow(rep..

• format_list_bulleted 독서/코틀린 코루틴
• · 2025. 6. 18.

[ 코틀린 코루틴 - 23장 ] 플로우 처리

Flow 처리는 데이터 스트림을 변환, 필터링, 결합하는 등의 작업을 통해 원하는 형태로 가공하는 과정입니다. 이는 반응형 프로그래밍의 핵심 개념으로, 안드로이드 개발에서 UI 상태 관리나 데이터 처리에 매우 유용합니다.주요 Flow 처리 함수들1. map - 데이터 변환의 핵심map 함수는 Flow의 각 원소를 다른 값으로 변환할 때 사용하는 가장 기본적이면서도 중요한 연산자입니다. 원본 데이터를 유지하면서 새로운 형태의 데이터로 변환하는 역할을 합니다. suspend fun main() { flowOf(1, 2, 3) .map { it * it } // 각 원소를 제곱 .collect { print(it) } // 149} 동작 원리:상위 Flow에서 각 원소가 방출될..

• format_list_bulleted 독서/코틀린 코루틴
• · 2025. 6. 18.

[ 코틀린 코루틴 - 22장 ] 플로우 생명주기 함수

Flow는 단순히 데이터를 변환하고 필터링하는 것을 넘어서, 생명주기의 각 단계에서 부가적인 작업을 수행할 수 있는 강력한 함수들을 제공합니다. 이러한 생명주기 함수들은 실제 안드로이드 개발에서 로깅, UI 상태 관리, 리소스 정리 등에 필수적으로 사용됩니다. onEach - 각 원소마다 부가 작업 실행onEach는 Flow의 각 원소가 방출될 때마다 지정된 함수를 실행하는 연산자입니다. kotlinsuspend fun main() { flowOf(1, 2, 3, 4) .onEach { println("Processing: $it") } .collect { println("Collected: $it") }} 출력:Processing: 1Collected: 1Process..

• format_list_bulleted 독서/코틀린 코루틴
• · 2025. 6. 18.

[ 코틀린 코루틴 - 18장 ] 핫 데이터 소스와 콜드 데이터 소스

우리가 사용하는 대부분의 데이터 소스는 두 가지 종류로 구분이 가능하기 때문에 핫 스트림 데이터와 콜드 스트림 데이터의 차이를 이해하는 것이 소프트웨어적인 측면에서 상당히 유용함 핫콜드컬렉션 (List, Set)Sequence, StreamChannelFlow, RxJava 스트림 핫 vs 콜드Hot과 Cold 데이터 스트림의 차이는 아래와 같다. 핫 데이터 스트림데이터를 소비하는 것과 무관하게 원소를 생성항상 사용 가능한 상태이며, 여러 번 사용 되었을 때 결과를 다시 계산할 필요가 없음fun main() { val l = listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10) .map { m(it) } // m1 m2 m3 m4 m5 m6 m7 m8 m..

• format_list_bulleted 독서/코틀린 코루틴
• · 2025. 6. 3.

[ 코틀린 코루틴 - 17장 ] 셀렉트

코루틴 select코루틴은 가장 먼저 완료되는 코루틴의 결과를 기다리는 select 함수를 제공함 select 함수는 아래와 같이 활용될 수 있음여러 개의 채널 중 버퍼에 남은 공간이 있는 채널을 먼저 확인하여 데이터를 보내기이용 가능한 원소가 있는 채널로부터 데이터를 받을 수 있는지 여부 확인코루틴 사이에 경합을 일으키거나, 여러 개의 데이터 소스로부터 나오는 결괏값을 합치기 지연되는 값 선택하기여러 개의 소스에 데이터를 요청한 뒤, 가장 빠른 응답만 얻는 경우여러 개의 요청을 비동기 프로세스로 시작한 뒤, select 함수를 사용하는 방법으로 가능아래 코드는 하나의 비동기 작업이 완료됨과 동시에 결과값을 반환함suspend fun requestData1(): String { delay(100_0..

• format_list_bulleted 독서/코틀린 코루틴
• · 2025. 6. 3.

[ 코틀린 코루틴 - 16장 ] 채널

채널interface SendChannel { supsend fun send(element: E) fun close(): Boolean //...}interface ReceiverChannel { suspend fun receive(): E fun cancel(cause: CancellationException? = null) //...}interface Channel : SendChannel, ReceiveChannel SendChannel- 원소를 보내거나(또는 더하거나) 채널을 닫는 용도 ReceiveChannel- 원소를 받을 때(또는 꺼낼 때) 사용 두 인터페이스는 구분되어 있으며, 채널의 진입점을 제한하기 위해 ReceiveChannel이나 SendChannel..

• format_list_bulleted 독서/코틀린 코루틴
• · 2025. 6. 3.