/**
 * 订阅事件じけん(EventFlow)或ある状じょう态(StateFlow)
 *
 * - 对于 [EventFlow]，进入 [minState] 开始订阅，脱だつ离 [minState] 取消とりけし订阅
 * - 对于 [StateFlow]，满足 [minState] 时立刻こく消しょう费，不足ふそく [minState] 时缓存そん最近さいきん的てき事件じけん待まち再さい次つぎ进入时消费
 *
 */
fun <T> Flow<T>.observe(owner: LifecycleOwner, minState: Lifecycle.State = Lifecycle.State.STARTED, action: suspend (T) -> Unit)


/**
 * 订阅事件じけん，满足 [minState] 时立刻こく消しょう费，不足ふそく [minState] 时缓存そん最近さいきん的てき事件じけん待まち再さい次つぎ进入时消费
 *
 * 示しめせ例れい：在ざいA页观察流，然しか后きさき进入B页发送了りょう事件じけん，回かい到いたA页消费事件じけん
 */
fun <T> Flow<T>.observeLatest(owner: LifecycleOwner, minState: Lifecycle.State = Lifecycle.State.STARTED, action: suspend (T) -> Unit)


/**
 * 进入 [minState] 开始订阅，脱だつ离 [minState] 取消とりけし订阅
 * */
fun <T> Flow<T>.observeRepeat(owner: LifecycleOwner, minState: Lifecycle.State = Lifecycle.State.STARTED, action: suspend (T) -> Unit)

data class FooEvent(val value: String)
data class BarEvent(val value: String)

object Global {
    val eventFoo = EventFlow<FooEvent>()

    val stateCount = MutableStateFlow(0)
}

Global.stateCount.observe(this) {
    binding.state.text = "count = $it"
}
Global.eventFoo.observeLatest(this) {
    log("Global => $it")
} 
EventBus.observe<BarEvent>(this) {
    log("EventBus => $it")
}

binding.fooEvent.setOnClickListener {
    Global.eventFoo.tryEmit(FooEvent("clicked in main"))
}
binding.barEvent.setOnClickListener {
    EventBus.emit(BarEvent("clicked in main"))
}