在不中断流管道的情况下引用先行Java流步骤？

Question

我是函数式编程新手，我正在努力变得更好。

目前，我正在试验一些代码，采用以下基本形式：

private static int myMethod(List<Integer> input){
      Map<Integer,Long> freq = input
        .stream()
        .collect(Collectors.groupingBy(Function.identity(), Collectors.counting()));
      
      return (int) freq
        .keySet()
        .stream()
        .filter(key-> freq.containsKey(freq.get(key)))
        .count();
    }

首先，使用hashmap获取列表中每个数字的频率。下一步，我们总结出地图中作为键存在的键的数量。

我不喜欢的是，这两个流需要彼此分开存在，其中一个HashMap是由一个流生成的，只会被另一个流立即独占地使用。

有没有一种方法可以将其合并为一个流？我是这样想的：

private static int myMethod(List<Integer> input){
      return (int) input
        .stream()
        .collect(Collectors.groupingBy(Function.identity(), Collectors.counting()))
        .keySet()
        .stream()
        .filter(key-> freq.containsKey(freq.get(key)))
        .count();
    }

但这里的问题是没有可参考的freq map，因为它被用作管道的一部分，所以过滤器无法完成它需要做的事情。

总之，我不喜欢这样的情况，即只收集到hashmap，然后再转换回密钥集。有没有一种方法可以“简化”（双关语）这个操作来

1. 不能从流和hashmap来回
2. 以一种不需要在管道之前声明单独映射的方式引用自己。

非常感谢。

Answer 1

键集实际上是由输入组成的哈希集。因此，您应该使用临时存储，以便：

Set<Integer> freq = new HashSet<>(input);

并进一步计数，根据单个流管道中的值进行筛选

return (int) input
        .stream()
        .collect(Collectors.groupingBy(Function.identity(),
                Collectors.counting()))
        .values() // just using the frequencies evaluated
        .stream()
        .filter(count -> freq.contains(count.intValue()))
        .count();