时间戳

首页 > 解决方案 > scala中带有期货的咖喱函数

scala - scala中带有期货的咖喱函数

问题描述

我正在学习 scala 并想了解如何Futures为咖喱函数实现

import scala.concurrent.{Await, Future}
import scala.concurrent.duration.Duration
import scala.concurrent.ExecutionContext.Implicits.global

object MainApp {

  def main(args: Array[String]): Unit = {

    val x = curriedMultiply(10) _ andThen Await.result(curriedAdd(10),Duration.Inf)

    println(x(2))



  }

  def curriedAdd(x: Int)(y: Int) : Future[Int]= Future {
    x + y
  }

  def curriedMultiply(x: Int)(y: Int) : Future[Int] = Future {
    x * y
  }

}

获取值时出现以下编译器错误

Type mismatch, expected: Awaitable[NotInferedT], actual: Int => Future[Int]

标签： scalafunction-composition

解决方案

我假设您正在尝试组合两个Int => Future[Int]类型的函数（应用第一个参数后两个函数的类型），然后在参数上执行结果函数2并等待结果。如果我的假设是正确的，那么您不能只使用andThen，因为您需要对函数的域（输入类型）和共域（输出类型）不同的行为进行建模。

您可以通过以下方式采用原生 scala 方式：

def combine(x:Int) = curriedMultiply(10)(x) flatMap (curriedAdd(10))
//or: val combine  = curriedMultiply(10)(_:Int) flatMap curriedAdd(10)

val y = Await.result(combine(2),Duration.Inf)

println(y)

或使用cats库，因为类型的函数Int => Future[Int]是Kleisli函数，所以你可以组合它们：

import cats.data.Kleisli
import cats.implicits._

val kfk = Kleisli(curriedAdd(10)) compose Kleisli(curriedMultiply(10))

val x = Await.result(kfk(2),Duration.Inf)

println(x)

你能解释一下平面图是如何在这里工作的吗？

combine将函数应用于参数时会发生以下情况2：

  1. curriedMultiply(10)(2)返回Future[Int]包含10 * 2值 ( Future(10 * 2))
  2. curriedAdd(10)返回Int => Future[Int]函数是y:Int => Future(10 + y)
  3. 现在你有Future(10 * 2).flatMap(y => Future(10 + y))
  4. flatMapFuture由其参数的函数产生的返回值。其中 y是左侧Future计算值产生的值20

推荐阅读