안드로이드 Android 애니메이션으로 Flow 이해하기

 

핫 스트림

• 데이터를 소비하는 것과 무관하게 원소를 생성
• Coroutines Channel
• 컬렉션(List, Set)

 

콜드 스트림

• 요청이 있을 때만 작업을 수행
• Sequence, Stream
• Flow, RxJava 스트림

 

Flow

• Flow를 무기 아이템 공장 안에 있는 컨베이어 벨트라고 생각💨
• 각각의 아이템들을 데이터라고 생각
• 무기 저장고에서 무기(데이터)들을 랜덤 하게 실시간으로 생성하고, 각 상황들을 저장해 보자!

sealed class Weapon {
    class Sword(): Weapon()
    class Staff(): Weapon()
    class SpellBook(): Weapon()
}

 

Flow 생성

val weaponProducer: Flow<Weapon>

• Flow를 생성하는 일반적인 방법 → 코루틴 채널의 produce와 비슷한 형태의 빌더 flow 선언
• Flow는 값이 필요할 때만 생성하기 때문에, 따지고 보면 빌더는 아니고 collect() 같은 최종 연산 시 데이터가 어떻게 처리할지 정의한 것

 

Emit과 Collect

• 새로운 무기(데이터)가 생성될 때마다 weaponProducer는 emit() 함수를 호출한다.
• collect()를 호출하여 무기(데이터)를 수신

import kotlinx.coroutines.flow.flow

private val weaponProducer: Flow<Weapon> = flow {
    emit(Weapon.Sword())
    emit(Weapon.Staff())
    emit(Weapon.SpellBook())
}
private val weaponBox = mutableListOf<Weapon>()

suspend fun main() {
    weaponProducer.collect { weapon ->
        weaponBox.add(weapon)
    }
}

 

Kotlin Flow의 Operators 종류

1. Terminal Operators
   • Flow의 실행을 시작하거나 최종 작업을 수행하는 데 사용
   • collect(), first(), last() 등
2. Intermediate Operators
   • 데이터를 변환, 필터링 또는 조작
   • Flow를 실행하지 않으며, 데이터를 어떻게 처리할지 정의
   • filter, map, transform 등

 

Intermediate Operators

Filter

• 특정 조건을 충족하는 요소를 선택
• 무기가 Sword인 경우만 collect()

weaponProducer
  .filter { weapon -> 
    weapon is Sword
  }.collect()

 

DistinctUntilChanged

• 연속된 중복 요소를 필터링
• 이전 값과 다른 경우에만 emit 가능

weaponProducer
  .distinctUntilChanged()
  .collect()

 

Map

• 각 입력 요소를 변환하는 데 사용
• 원래 Flow나 Collection을 변경하지 않고, 변환된 값으로 새롭게 만든다.
• 일반 무기(Weapon)에서 EnchantedWeapons로 변환

weaponProducer
  .map { weapon -> 
      mapToEnchantedWeapon(weapon)
   }.collect()

 

FlatMap

• Map은 각 요소를 개별적으로 변환
• FlatMap은 각 요소를 다른 Flow로 변환 후 이들을 변환

 

Map의 내부 구현

inline fun <T, R> Flow<T>.map(
  crossinline transform: suspend (value: T) -> R
): Flow<R>

 

FlatMap의 내부 구현

inline fun <T, R> Flow<T>.flatMapLatest(
    crossinline transform: suspend (value: T) -> Flow<R>
): Flow<R>

• 각각의 요소를 Flow로 리턴한 후, 그 Flow들을 병합

val weaponTypes: Flow<WeaponType> = queryWeaponTypes()

private fun produceWeapons(weaponType: WeaponType): Flow<Weapon> {
  // Emit weapons of the specified type
}

weaponTypes
  .flatMap { type -> 
    produceWeapons(type)
  }.collect()

• WeaponType이 방출되면서 Flow<Weapon>이 생성

 

Zip

• 두 Flow를 결합하여 대응하는 요소들을 Pair로 묶어 새로운 요소를 생성
• Flow A의 첫 번째 요소와 Flow B의 첫 번째 요소가 짝을 이루고, 두 번째 요소끼리 짝을 이루고 . . .
• enchantments flow와 weapons flow를 결합하여 EnchentedWeapons를 생성

val enchantments: Flow<Enchantment> = queryEnchantments()
val weapons: Flow<Weapon> = queryWeapons()

enchantments.zip(weapons) { enchantment, weapon -> 
    createMagicWeapon(enchantment, weapon)
    }

 

결론

Flow를 시각화해서 볼 수 있어서 쉽고 재밌게 이해가 가능했다! 😎

Flow를 자유자재로 사용하면 정말 편리하게 데이터를 실시간으로 반영할 수 있을 것 같다!!

 

해당 포스팅의 원문은 아래 링크를 참고해 주세요.

 

Reference

https://medium.com/@robert.baricevicpetrus/kotlin-flows-animated-55640aa48ac9

Kotlin Flows Animated