泛型参数scala的访问类型参数

Question

我正在尝试对 Akka 流中的以下函数进行包装。

RestartFlow.withBackoff(minBackoff = 3.seconds,
      maxBackoff = 30.seconds,
      randomFactor = 0.2) {
      () => s
    }

其中 s 是我用后退包装的一些来源。理想情况下像这样的 ID

RetryFlow(s)

我成功创建了这个：

object RetryFlow {
  def apply[In, Out, _, T <: Flow[In, Out, _]](source: T, minBackoff: FiniteDuration = 3.seconds, maxBackoff: FiniteDuration = 30.seconds, randomFactor: Double = 0.2): Flow[In, Out, NotUsed] = {
    RestartFlow.withBackoff(
      minBackoff = minBackoff,
      maxBackoff = maxBackoff,
      randomFactor = randomFactor) {
      () => source
    }
  }
}

问题是我需要在调用站点再次提供流的所有 3 种类型参数，这看起来很糟糕

RetryFlow[JustDataEvent, JustDataEvent, NotUsed, Flow[JustDataEvent, JustDataEvent, NotUsed]](s)

它也不是类型安全的，因为我可以在这里输入任何类型参数。

我觉得应该是可能的，但我不确定如何不采用额外的类型参数 In 和 Out，而是做一些像 T#In、T#Out 等的事情，因为我已经说过 T extends flow，因此，T已经有了我需要的类型参数。

Answer 1

如何代替 T，仅采用类型 Flow[In, Out, _] 的参数？

object RetryFlow {
  def apply[In, Out, _](
      source: Flow[In, Out, _],
      minBackoff: FiniteDuration = 3.seconds,
      maxBackoff: FiniteDuration = 30.seconds,
      randomFactor: Double = 0.2): Flow[In, Out, NotUsed] = {
    RestartFlow.withBackoff[In, Out](minBackoff = minBackoff,
                            maxBackoff = maxBackoff,
                            randomFactor = randomFactor) { () =>
      source
    }
  }
}

然后我们得到：

val value: Flow[Int, String, NotUsed] = Flow.fromFunction[Int, String](i => i.toString)
RetryFlow(value)

泛型参数scala的访问类型参数

Access type parameters of generic parameter scala

scala

generics

akka-stream

scala-generics