什么是Java流的（类）反向操作。flatMap（）？

Question

Stream.flatMap（）操作将

a, b, c

转换为包含每个输入元素的零个或多个元素的流，例如。

a1, a2, c1, c2, c3

是否有相反的操作将几个元素分批添加到一个新的元素中？

• 事实并非如此。reduce（），因为这只产生一个结果
• 它不是collect（），因为它只填充一个容器（afaiu）
• 它不是forEach（），因为它只返回void，并且具有副作用

它存在吗？我可以用任何方式模拟它吗？

Answer 1

    IntStream.range(0, 10)
            .mapToObj(n -> IntStream.of(n, n / 2, n / 3))
            .reduce(IntStream.empty(), IntStream::concat)
            .forEach(System.out::println);

如您所见，元素也映射到Streams，然后连接成一个大流。

Answer 2

你可以绕过去。请参见以下示例：

Stream<List<String>> stream = Stream.of("Cat", "Dog", "Whale", "Mouse")
   .collect(Collectors.collectingAndThen(
       Collectors.partitioningBy(a -> a.length() > 3),
       map -> Stream.of(map.get(true), map.get(false))
    ));

Answer 3

最后，我弄清楚了，可以说平贴图是它自己的“逆”。我监督了平贴图不一定会增加元素的数量。它还可以通过为某些元素发出空流来减少元素的数量。为了实现按组操作，平贴图调用的函数需要最小的内部状态，即最近的元素。它要么返回一个空流，要么在组的末尾返回简化为组的代表。

这是一个快速实现，如果传入的两个元素不属于同一个组，即它们之间是组边界，则group边境必须返回true。组合器是将例如（1， a）、（1， a）、（1， a）组合成（3， a）的组函数，前提是您的组元素是元组（int， string）。

public class GroupBy<X> implements Function<X, Stream<X>>{

  private final BiPredicate<X, X> groupBorder;
  private final BinaryOperator<X> combiner;
  private X latest = null;

  public GroupBy(BiPredicate <X, X> groupBorder,
                 BinaryOperator<X> combiner) {
    this.groupBorder = groupBorder;
    this.combiner = combiner;
  }

  @Override
  public Stream<X> apply(X elem) {
    // TODO: add test on end marker as additonal parameter for constructor
    if (elem==null) {
      return latest==null ? Stream.empty() : Stream.of(latest);
    }
    if (latest==null) {
      latest = elem;
      return Stream.empty();
    }
    if (groupBorder.test(latest, elem)) {
      Stream<X> result = Stream.of(latest);
      latest = elem;
      return result;
    }
    latest = combiner.apply(latest,  elem);
    return Stream.empty();
  }
}

但是有一个警告：要发布整个流的最后一组，必须将结束标记作为流中的最后一个元素粘住。上面的代码假定它是null，但可以添加一个额外的end-mark-tester。

我无法想出一个不依赖终点标记的解决方案。

此外，我也没有在传入和传出元素之间进行转换。对于唯一操作，这只是工作。对于计数操作，前一步必须将单个元素映射到计数对象。