1

我有一些方法的调用链,我通过 Kleisli 传递上下文。基本上我想将上下文传递给数据库访问层,但我想在两者之间的任何地方访问这个上下文。

以下示例完美运行。我的问题是,我也想访问上下文OrderService.findAll(...)。我尝试了几种方法,但我一直失败。

object OrderRepository {
    fun findAll(userId: String): Kleisli<Context, ForIO, List<Order>> =
        Kleisli { ctx ->
            IO {
                ctx.db.query("someQuery")
            }
        }
}

object OrderService {
    fun findAll(userId: String): Kleisli<Context, ForIO, List<OrderResponse>> =
         OrderRepository.findAll(userId).map(IO.monad()) { orderList ->
            orderList.map {
                //Create OrderResponse from Order
            }
        }
}

是否可以访问那里的上下文,或者这没有任何意义?谢谢您的帮助 :)

4

2 回答 2

3

你需要的是一个从 D 到 D 的 Kleisli,以 D 作为上下文。这样,您也可以将 D(上下文)作为结果类型,并且您可以使用 flatMap 并访问它。这就是为什么 ask() 方法提供,可通过同伴获得的原因。

假设您OrderRepository也是 Context 中的依赖项,而不是纯函数(为了示例),因此您需要从服务的上下文中访问它。看:

interface OrderApi
interface OrderDB {
  fun query(query: String): List<Order> = TODO()
}

data class Order(val id: String)
data class OrderResponse(val order: Order)
data class Context(val api: OrderApi, val repository: OrderRepository, val db: OrderDB)

class OrderRepository {
  fun findAll(userId: String): Kleisli<Context, ForIO, List<Order>> =
    Kleisli { ctx ->
      IO {
        ctx.db.query("someQuery")
      }
    }
}

object OrderService {
  fun findAll(userId: String): Kleisli<Context, ForIO, List<OrderResponse>> {
    val monad = IO.monad()
    return Kleisli.ask<Context, ForIO>(monad).flatMap(monad) { ctx ->
      ctx.repository.findAll(userId).map(monad) { orderList ->
        orderList.map { OrderResponse(it) }
      }
    }
  }
}

也就是说,Kleisli 是一个 Monad 转换器(也称为 ReaderT),使用起来可能有点复杂。如果您想在功能代码库上注入依赖项并保持更简单,我的建议是通过 Context 接收器使用扩展函数,它已经隐式地跨所有级别传递您的依赖项,Paco 在这篇文章中对此进行了描述。

于 2020-06-15T14:54:24.620 回答
3

@brewcode @bob 在 FP 中有一个高于 MTL 等编码的高阶模式,它是定界的延续,是所有 monad 的母亲。这包含了整个 Functor 层次结构的命令式语法,包括像阅读器这样的单子,通过延续将应用程序语法引入环境。这就是 kotlin 的暂停。

@Jorge Castillo 的问题是正确的,但是任何支持延续的语言都比以分配成本包装数据类型具有更好的抽象。

对于 JS 和 TS,而不是像 ReaderT 这样的 Haskell 编码或任何回调样式编码,如 Scala 和 Haskell 提出的基于定界延续的编码,如果这些语言中有一种方法比包装回调更清洁和更易于初学者使用ReaderT 建议的风格。查看下面的程序,看看它是否比包装版本有任何缺点。

interface OrderApi

interface OrderDB {
  fun query(query: String): List<Order> = TODO()
}

data class Order(val id: String)

data class OrderResponse(val order: Order)

data class Context(
  val api: OrderApi,
  val repository: OrderRepository,
  val db: OrderDB) : OrderApi by api, OrderRepository by repository, OrderDB by db

interface OrderRepository {
  suspend fun Context.findAll(userId: String): List<Order> =
    query("someQuery")
}

object OrderService {
  suspend fun Context.findAll(userId: String): List<OrderResponse> =
    findAll(userId).map(::OrderResponse)
}
于 2020-06-15T15:48:49.953 回答