Kotlin多平台流量块转换为iOS的自定义包装器流量使用

Question

我有一个Kotlin多平台项目，该项目包含Apollo GraphQl API

在此项目中，我有BaseerePository类，在此类中，有一种执行查询或突变的方法

suspend fun <D : Query.Data> executeQuery(query: Query<D>): ApolloResponse<D> {
        val response = getApolloClient().query(query).execute()

        checkOperation(response)

        return response
    }

    suspend fun <D : Mutation.Data> executeMutation(mutation: Mutation<D>): ApolloResponse<D> {
        val response = getApolloClient().mutation(mutation).execute()

        checkOperation(response)

        return response
    }

例如，我想使用此方法在这样的存储库中，

class HelpRepository : BaseRepository() {

    fun test(request: AddFeedBackRequest) = flow {

        val feedBackType = if (request.type == AddFeedBackType.Bug) {
            FeedbackType.BUG
        } else {
            FeedbackType.FEEDBACK
        }

        val input = AddFeedbackInput(request.note, Optional.presentIfNotNull(feedBackType))

        emit(true)

        val mutation = AddFeedbackMutation(input)

        val response = executeMutation(mutation)

        emit(false)

    }
}

当我添加流程范围时，我不必将此方法转换为悬挂函数，

我不想因为iOS应用而不想使用悬挂函数。当我使用悬挂函数时，Xcode中的“ Kotlinx_coroutines_coreflowcollector”转换为“ kotlinx_coroutines_coreflowcollector”，

因此我在使用单个变量的包装器时找到了像This this this warper的包装器函数

fun <T> Flow<T>.asCommonFlow(): CommonFlow<T> = CommonFlow(this)
class CommonFlow<T>(private val origin: Flow<T>) : Flow<T> by origin {
    fun listen(block: (T) -> Unit): Closeable {
        val job = Job()

        onEach {
            block(it)
        }.launchIn(CoroutineScope(Dispatchers.Main + job))

        return object : Closeable {
            override fun close() {
                job.cancel()
            }
        }
    }
}

工作。。

，它在Xcode中完全可以 t找到一种适当的方法来执行此操作

我需要一个像

= commonFlow {
}

instead of this

= flow {
}

这样的包装器，以将此方法用作通用流包装器

您能帮我吗？

Answer 1

我们在一个项目中有几乎相同的事情。我们具有将常规流量转换为“常见”流的扩展函数，因此可以在Android和iOS中使用。

您可以像往常一样创建流，并在最后包装。

fun <T> Flow<T>.wrap(): CommonFlow<T> = CommonFlow(this)

class HelpRepository : BaseRepository() {

fun test(request: AddFeedBackRequest) = flow {

    val feedBackType = if (request.type == AddFeedBackType.Bug) {
        FeedbackType.BUG
    } else {
        FeedbackType.FEEDBACK
    }

    val input = AddFeedbackInput(request.note, Optional.presentIfNotNull(feedBackType))

    emit(true)

    val mutation = AddFeedbackMutation(input)

    val response = executeMutation(mutation)

    emit(false)

}
}.wrap()