为什么使用Stream :: flatMap是错误的？

Question

我希望能够像这样使用Stream :: flatMap

public static List<String> duplicate(String s) {

    List<String> l = new ArrayList<String>();
    l.add(s);
    l.add(s);

    return l;
}


listOfStrings.stream().flatMap(str -> duplicate(str)).collect(Collectors.toList());

但是我得到以下编译器错误

Test.java:25：错误：不兼容的类型：无法推断类型变量R listOfStrings.stream（）。flatMap（str->
plicate（str））。collect（Collectors.toList（））;

（参数不匹配； lambda表达式List中的错误返回类型无法转换为Stream）
，其中R，T是类型变量：R扩展了在flatMap（Function>）方法中声明的对象T扩展了在接口Stream中声明的对象

在斯卡拉，我可以做我认为等同的事情

scala> List(1,2,3).flatMap(duplicate(_))
res0: List[Int] = List(1, 1, 2, 2, 3, 3)

为什么这不是Java中flatMap的有效用法？

Answer 1

的lambda表达式flatMap需要返回a Stream，这可以通过参数flatMap为type
看到Function<? super T, ? extends Stream<? extends R>>。

以下代码将编译并正常运行：

listOfStrings.stream()
             .flatMap(str -> duplicate(str).stream()) // note the .stream() here
             .collect(Collectors.toList());

因为lambda表达式str -> duplicate(str).stream()的类型是Function<String, Stream<String>>。