kotlin - 如何在 Kotlin Arrow FX 中组合 IO 函数和其他效果

Question

在处理请求之前，我们经常需要一些请求验证。使用箭头 v 0.8，典型的消息处理程序如下所示:

fun addToShoppingCart(request: AddToShoppingCartRequest): IO<Either<ShoppingCardError, ItemAddedEvent>> = fx {
    request
    .pipe (::validateShoppingCard)
    .flatMap { validatedRequest ->
        queryShoppingCart().bind().map { validatedRequest to it }         // fun queryShoppingCart(): IO<Either<DatabaseError, ShoppingCart>>
    }
    .flatMap { (validatedRequest, shoppingCart) ->
        maybeAddToShoppingCart(shoppingCart, validatedRequest)            // fun maybeAddToShoppingCart(...): Either<DomainError, ShoppingCart>
    }
    .flatMap { updatedShoppingCart ->
        storeShoppingCart(updatedShoppingCart).bind()                     // fun storeShoppingCart(ShoppingCart): IO<Either<DatabaseError, Unit>>
        .map {
            computeItemAddedEvent(updatedShoppingCart)
        }
    }
    .mapLeft(::computeShoppingCartError)
}

这似乎是对工作流的一种方便且富有表现力的定义。我试图在箭头 v 0.10.5 中定义类似的函数:

fun handleDownloadRequest(strUrl: String): IO<Either<BadUrl, MyObject>> = IO.fx {
    parseUrl(strUrl)                                                      // fun(String): Either<BadUrl,Url>
    .map {
        !effect{ downloadObject(it) }                                     // suspended fun downloadObject(Url): MyObject
    }
}

这会导致编译器错误“只能在协程体内调用暂停函数”。原因是 Either 和 Option 的 map 和 flatMap 函数都不是 inline .

的确，blog post关于外汇说

"Soon you will find that you cannot call suspend functions inside the functions declared for Either such as the ones mentioned above, and other fan favorites like map() and handleErrorWith(). For that you need a concurrency library!"

那么问题是为什么会这样，这种组合的惯用方式是什么？

Answer 1

惯用的方式是

fun handleDownloadRequest(strUrl: String): IO<Either<BadUrl, MyObject>> =
    parseUrl(strUrl)
      .fold({
        IO.just(it.left())  // forward the error
      }, {
        IO { downloadObject(it) }
          .attempt() // get an Either<Throwable, MyObject>
          .map { it.mapLeft { /* Throwable to BadURL */ } } // fix the left side
      })

就我个人而言，我不会深入研究 IO，而是将其重写为挂起函数

suspend fun handleDownloadRequest(strUrl: String): Either<BadUrl, MyObject> =
    parseUrl(strUrl)
      .fold(::Left) { // forward the error
        Either.catch({ /* Throwable to BadURL */ }) { downloadObject(it) }
      }

发生的事情是，在 0.8.X 中，Either 的函数曾经是内联的。这样做的一个意想不到的副作用是您可以在任何地方调用挂起函数。虽然这很好，但它可能导致在 map 中间抛出异常(或跳转线程或死锁🙈)。或 flatMap ，这对正确性来说很糟糕。这是拐杖。

在 0.9(或者是 10？)中，我们删除了那个拐杖并将它变成了 API 中的明确内容:Either.catch .我们保留了fold内联因为它与 when 相同，所以那里没有真正的正确性权衡。

因此，推荐使用 suspend到处都是IO当尝试执行线程、并行、取消、重试和调度，或任何真正高级的事情时。

对于基本用例 suspend和 Either.catch足够。拨入suspend在程序的边缘或需要与这些高级行为桥接的地方运行，然后使用 IO .

如果您想继续使用 Either，您可以定义常规函数的挂起/内联版本，风险自负；或等到IO<E, A>在 0.11 中你可以使用 effectEither 和 effectMapEither .