将泛型类作为输入传递给 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);
  }

Answer 2

我会使用 create() 方法，并将类型参数用作：

Flow.<Pair<A, B>>create().map(// your lambda function)