具有一元约束的 HList 可变参数转换

Question

假设我们有这个：

def join[A, B](a: A, b: B)
def join[A, B, C](a: A, b: B, c: C) // etc

基本上有很多重载方法最多 20 个类型参数。

然后下面是通过在 HList 上强制执行一元类型约束来创建 K-list，这样所有内部元素都是 Task[_].

类型

class Test(L <: HList : *->*[Task]#λ](val deps : L = HNil)

是否可以将 deps 转换为 Task[A1, A2, A3] 等，其中 A1、A2、A3 是 HList?

因此：

val hls = Task(1) :: Task("string") :: Task9(true) :: HNil

检索一个：

Task[(Int, String, Boolean)]

并为任意数量的参数执行此操作？对于任何数量的参数，我都可以将 Task[A], Task[B] 转换为 Task[A, B]，只需要从 HList 转换为 varargs 或类似的。

Answer 1

从 Scala 的角度来看，这些 join 方法除了它们的名称外没有任何共同点，因此如果没有大量样板（或自定义宏），就不可能在这种情况下使用它们。相反，可以在 Twitter 的 Future 本身上重复使用 join。您可以通过创建一个新类型 class:

来做到这一点

import shapeless._

trait FutureSequence[L <: HList] extends DepFn1[L]

这种类型 class 将见证 hlist L 完全由未来组成，它会为我们提供一种将这些未来排序为 Future[T] 的方法，其中 T 是由 L 中每个未来的类型组成的元组（*->* 给了我们第一部分，但不支持第二部分，甚至不支持任何完全方便地完成第二部分的方法）。

伴随对象完成所有有趣的工作：

import com.twitter.util.Future
import shapeless.ops.tuple.Prepend

object FutureSequence {
  type Aux[L <: HList, Out0] = FutureSequence[L] { type Out = Out0 }

  implicit def hnilFutureSequence: Aux[HNil, Future[Unit]] =
    new FutureSequence[HNil] {
      type Out = Future[Unit]
      def apply(l: HNil): Future[Unit] = Future.Unit
    }

  implicit def hconsFutureSequence[H, T <: HList, OutT](implicit
    fst: Aux[T, Future[OutT]],
    pre: Prepend[Tuple1[H], OutT]
  ): Aux[Future[H] :: T, Future[pre.Out]] = new FutureSequence[Future[H] :: T] {
    type Out = Future[pre.Out]

    def apply(l: Future[H] :: T): Future[pre.Out] =
      l.head.join(fst(l.tail)).map {
        case (h, t) => pre(Tuple1(h), t)
      }
  }
}

我们在这里使用归纳——首先我们描述如何排序 HNil（我们的基本情况），然后我们描述如何排序 Future[H] :: T，因为我们知道如何排序 T.

接下来我们将定义一个方法来使其易于使用：

def sequence[L <: HList](l: L)(implicit fs: FutureSequence[L]): fs.Out = fs(l)

然后，如果我们有一些示例：

 val good = Future(1) :: Future("string") :: Future(true) :: HNil
 val bad = Future(1 / 0) :: Future("string") :: Future(true) :: HNil

我们可以对它们进行排序：

scala> import com.twitter.util.Await
import com.twitter.util.Await

scala> Await.result(sequence(good))
res0: (Int, String, Boolean) = (1,string,true)

scala> sequence(bad).onFailure(println)
java.lang.ArithmeticException: / by zero
res1: com.twitter.util.Future[(Int, String, Boolean)] = ...

您还可以在 class 的构造函数中或在 class.

的特定方法中需要一个 FutureSequence 实例

具有一元约束的 HList 可变参数转换

HList with unary constrain to varargs cast

scala

shapeless