在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<…>>只能进行一次评估,因此将流处理为可重用的东西是不可避免的.如果它不应该是a 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);