플로우 테스트

플로우 테스트Flow를 반환하는 대부분의 함수는 Flow를 반환하는 다른 함수를 호출합니다.이는 데이터 → 도메인 레이어로 Flow 반환과 뷰 모델에서 UI 모델로의 전환에서도 적용됩니다.이러한 함수들을 어떻게 테스트하는지 직접 구현해봤습니다.비즈니스 로직테스트를 위한 로직을 구현하였습니다.ObserveAppointmentsService는 비즈니스 로직을 포함하고 있습니다.레퍼지토리 저장소로부터 Flow 데이터를 반환받아, 다양한 연산 후 재반환합니다.// Sealed Class 정의sealed class Appointment { data class AppointmentsUpdate(val appointments: List) : Appointment() data object Appointmen..

• format_list_bulleted Deep Dive/Kotlin Flow
• · 2025. 2. 18.
• textsms

공유플로우와 상태플로우

개요일반적으로 플로우는 콜드 데이터이기 때문에 요청할 때마다 값이 계산됩니다.여러 개의 수신자가 하나의 데이터가 변경되는지 감지하는 경우도 있습니다.이 경우 메일링 리스트와 비슷한 개념인 SharedFlow를 활용할 수 있습니다.StateFlow는 감지 가능한 값과 비슷하게 동작합니다.SharedFlow공유플로우를 통해 메시지를 보내면, 대기하고 있는 모든 코루틴이 수신하게 됩니다.이는 브로드캐스트 채널과 비슷하게 동작합니다.replay마지막으로 전송한 값들을 저장할 수를 지정합니다.(default:0)relayCache값을 저장한 캐시를 나타냅니다.resetReplayCache저장한 캐시를 초기화하는 경우 활용합니다.suspend fun main(): Unit = coroutineScope { /..

• format_list_bulleted Deep Dive/Kotlin Flow
• · 2025. 2. 18.
• textsms

플로우 생명주기 함수

플로우 생명주기 함수플로우는 요청이 한쪽 방향으로 흐르고, 요청에 의해 생성된 값이 다른 방향으로 흐르는 파이프 형태입니다.플로우가 완료되거나 예외가 발생하면 값이나 예외 같은 특정 이벤트를 감지할 수 있습니다.이 때 onEach, onStart, onCompletion, onEmpty와 같은 catch 메서드를 사용할 수 있습니다.onEachonEach는 중단 함수로, 순서대로 값을 하나씩 받아 처리할 수 있습니다.suspend fun main() { flowOf(1,2,3,4) .onEach { delay(1000) } .collect{ println(it) }}onEmpty예기치 않은 이벤트가 발생하면 플..

• format_list_bulleted Deep Dive/Kotlin Coroutine
• · 2025. 2. 10.
• textsms

플로우 구현하기

플로우 만들기플로우는 어디선가 시작되어야 하며, 필요한 경우에 따라 다양하게 시작할 수 있습니다.원시값을 가지는 플로우플로우를 가지는 가장 간단한 방법은 flowOf를 활용하는 것입니다.suspend fun main() { flowOf(1, 2, 3, 4, 5) .collect { print(it) }}컨버터asFlow 함수를 사용하여 Iterable, Iterator, Sequence를 Flow로 바꿀 수 있습니다.// asFlow 함수를 이용해 즉시 사용 가능한 원소들의 플로우를 만들 수 있습니다.suspend fun main(){ sequenceOf(1,2,3,4,5) // sequenceOf .toSet() //setOf .toList() // li..

• format_list_bulleted Deep Dive/Kotlin Coroutine
• · 2025. 2. 10.
• textsms

플로우 직접 구현하기

💡 flow 인터페이스와 flow 빌더가 실제로 어떻게 동작하는지 이해하기Flow 직접 구현플로우의 원리에 대해 이해하기 위해서 직접 코드로 구현하였습니다.FlowCollector람다식을 통해서 플로우 동작을 구현할 수 있습니다.람다식은 또한 함수를 나타내는 파라미터를 가질 수 있습니다.flow 동작을 이해하기 위해서 해당 파라미터를 emit으로 정의하였습니다.// 이전의 코드는 함수를 파라미터로 전달합니다.// 복잡한 함수형을 간결하게 만들기 위하여 함수형 인터페이스로 추상화합니다.private suspend fun before(){ val f: suspend ((T) -> Unit) -> Unit = { emit -> emit("flow 방출" as T) }}이 때 emit..

• format_list_bulleted Deep Dive/Kotlin Flow
• · 2025. 2. 4.
• textsms

플로우 이해하기

FlowKotlin Coroutines의 일부분으로 비동기적 데이터 스트림을 처리하는 API입니다.떠다니는 원소들을 모으는 역할을 하며, 플로우의 끝에 도달할 때까지 각 값을 처리하는 걸 의미합니다.collect는 컬렉션의 forEach와 비슷하게 동작합니다.특징소비자가 구독을 시작해야만 데이터 생산이 시작됩니다.메모리 효율적입니다.데이터를 비동기적으로 가져와 UI를 처단하지 않고 효율적으로 업데이트합니다.시간에 따라 발생하는 데이터 변화를 처리하는데 유용하며, Android에서는 StateFlow, SharedFlow의 형태로 구현하여 상태 관리와 이벤트 처리를 합니다.vs 컬렉션List, Set과 같은 값은 플로우 처럼 여러개의 값을 반환합니다.하지만 모든 원소의 계산이 완료될 때까지 기다려야 하기 ..

• format_list_bulleted Deep Dive/Kotlin Flow
• · 2025. 1. 24.
• textsms