将映射器流应用于Java8中的另一个流

Question

在 Java8 中，我有一个流，我想应用一个 映射器流。

例如：

Stream<String> strings = Stream.of("hello", "world");
Stream<Function<String, String>> mappers = Stream.of(t -> t+"?", t -> t+"!", t -> t+"?");

我想写：

strings.map(mappers); // not working

但我目前解决任务的最佳方式是：

for (Function<String, String> mapper : mappers.collect(Collectors.toList()))
    strings = strings.map(mapper);

strings.forEach(System.out::println);

我该如何解决这个问题

• 不将映射器收集到列表中
• 不使用for 循环
• 不破坏我流畅的代码

Answer 1

由于map 需要一个可以应用于每个元素的函数，但您的Stream<Function<…>> 只能评估一次，因此不可避免地将流处理为可重用的东西。如果不应该是Collection，只需将其缩减为单个Function：

strings.map(mappers.reduce(Function::andThen).orElse(Function.identity()))

完整示例：

Stream<Function<String, String>> mappers = Stream.of(t -> t+"?", t -> t+"!", t -> t+"?");
Stream.of("hello", "world")
      .map(mappers.reduce(Function::andThen).orElse(Function.identity()))
      .forEach(System.out::println);