java - 将通用类作为 Akka Streams Flow 的输入传递

Question

我想传递一个泛型类，如下面的代码所示，但出现异常:

Incompatible equality constraint `Pair<A, B>` and `Pair`.

我该如何纠正它？或者还有其他方法吗？

注:Flow.of(Pair<A, B>.class)不起作用。怎么通过Pair<A, B>而不是Pair ？

Flow<Pair<A, B>, B, NotUsed> func() {
  return Flow.of(Pair.class).map(i ->
    {
      B obj = i.second();
      return obj;
    });
}

Answer 1

对于简单的情况有一种解决方法:

  <A, B> Flow<Pair<A, B>, B, NotUsed> func(){
    return Flow.fromFunction(Pair::second);
  }