Android开发flow常见API的使用示例详解

public suspend inline fun  Flow.collect(crossinline action: suspend (value: T) -> Unit): Unit =
    collect(object : FlowCollector {
        override suspend fun emit(value: T) = action(value)
    })

fun main() {
    GlobalScope.launch {
        flow {
            emit("haha")
        }.collect {
        }
    }
}

public fun  Flow.launchIn(scope: CoroutineScope): Job = scope.launch {
    collect() // tail-call
}

fun main() {
    flow {
        emit("haha")
    }.launchIn(GlobalScope)
}

public fun  Flow.catch(action: suspend FlowCollector.(cause: Throwable) -> Unit): Flow =
    flow {
        val exception = catchImpl(this)
        if (exception != null) action(exception)
    }

public fun  merge(vararg flows: Flow): Flow = flows.asIterable().merge()

fun main() {
    GlobalScope.launch {
        merge(flow {
            delay(1000)
            emit(4)
        }, flow {
            println("flow2")
            delay(2000)
            emit(20)
        }).collect {
            println("collect value: $it")
        }
    }
}

public inline fun  Flow.map(crossinline transform: suspend (value: T) -> R): Flow = transform { value ->
   return@transform emit(transform(value))
}

fun main() {
    GlobalScope.launch {
        flow {
            emit(5)
        }.map {
            "ha".repeat(it)
        }.collect {
            println("collect value: $it")
        }
    }
}