如何在 Kotlin/Arrow.kt 中为生产者频道实现“铁路模式”

Question

我正在我当前的 Android 应用程序中研究 Kotlin Coroutines & Channels。

我有以下代码来管理远程 Api 调用和控制 UI 副作用

   private val historical: CompletableDeferred<List<Any>> = CompletableDeferred()
   private val mutex = Mutex()

    @ExperimentalCoroutinesApi
    fun perform(action: Action): ReceiveChannel<List<Any>> =
        produce {

          mutex.withLock {
            if (historical.isCompleted) {
                send(historical.getCompleted())
                return@produce
            }  

            send(action.sideEffects)
            val networkResponse = repository.perform(action)
            send(networkResponse.sideEffects)
            send(listOf(networkResponse)).also {
                    historical.complete(listOf(response))
                }
            }
        }

上面的代码给了我想要的结果，但是我想将它重构为类似的东西 函数式编程“铁路模式”https://android.jlelse.eu/real-world-functional-programming-with-kotlin-arrow-b5a98e72f5e3

我的流程在哪里

stepOne(Historical.completed)
.stepTwo(action.sideEffects)
.stepThree(getReaction())
.stepFour(reaction.sideEffects)
.finalStep(reaction)

这将在任何步骤失败或历史“已完成”时“短路”

在 Kotlin 中是否可以实现这种调用方式？和/或 Kotlin & Arrow.kt？

Answer 1

您可以使用 Arrow-kt 的Either。

您可以使用Either'smapLeft()、map()、flatMap()。

如果结果是Exception，请使用mapLeft()。来自mapLeft() 的返回值在结果Either 中将是新的Left，例如返回是String，结果将是Either<String, List<Any>>。如果结果是Right，即List<Any>，mapLeft() 将被跳过，但结果类型无论如何都会改变，因此您将拥有Either<String, List<Any>> 的类型，其值为Right<List<Any>>。如果您愿意，您也可以从mapLeft() 返回相同的Exception

如果您不需要处理特定错误，您可以链接map() 和flatMap()。 map() 基本上是 mapRight() 和 flatMap() 在您想要链接调用时很有用，即在链中的某处有一个 List<Any> 的接收器可能会失败并且您想以与 @987654346 相同的方式处理 Exception @ 对于那个电话，你可以从flatMap()返回新的Either

代码看起来像这样

fun perform(action: Either<Exception, Action>): ReceiveChannel<List<Any>> =
    produce {
        // if action is always right, you can start it as Right(action) but then first mapLeft does not make any sense
        if (historical.completed) action
            .mapLeft {
                // handle actions exception here
                // transform it to something else or just return it
                send(action.sideEffects)
                it
            }.flatMap {
                // handle right side of action either
                // assume here that repository may fail and returns Either<Exception, NetworkResponse>
                repository.perform(it)
            }.mapLeft {
                // handle repositorys exception here
                // transform it to something else or just return it
                send(it)
                it
            }.map {
                // handle network response
                send(listOf(networkResponse))
                historical.complete(listOf(networkResponse))
            }
    }