我需要编写一个流链,它将返回指定的控制台输出。
我设法获得适当的结果,但是我不得不中断流链,我想知道是否有任何方法可以避免这种情况
public class Main {
public static void main(String[] args) throws IOException {
Map<String, List<String>> map;
int maxValue;
map = new BufferedReader(
new InputStreamReader(
new URL("http://wiki.puzzlers.org/pub/wordlists/unixdict.txt")
.openStream(), StandardCharsets.UTF_8))
.lines().flatMap(Pattern.compile("[\\r\\n]")::splitAsStream)
.collect(Collectors.groupingBy(s -> Stream.of(s.split(""))
.sorted().collect(Collectors.joining()), Collectors.toList()));
maxValue = map.values().stream().mapToInt(List::size).max().getAsInt();
map.values().stream().filter(l -> l.size() == maxValue).collect(Collectors.toList())
.stream().sorted(Comparator.comparing(s -> s.get(0))).collect(Collectors.toList()).
forEach(n -> System.out.println(n.stream().sorted().collect(Collectors.joining(" "))));
}
}
我希望得到与代码相同的结果,但与其在流链之外设置maxValue,不如在流链中设置它。
最佳答案
您可以使用TreeMap
及其最后一个条目来收集所有最大值:
new BufferedReader(new InputStreamReader(new URL("http://wiki.puzzlers.org/pub/wordlists/unixdict.txt").openStream(), StandardCharsets.UTF_8))
.lines()
.collect(Collectors.groupingBy(s -> Stream.of(s.split("")).sorted().collect(Collectors.joining()), Collectors.toList()))
.entrySet().stream()
.collect(Collectors.groupingBy(e -> e.getValue().size(), TreeMap::new, Collectors.toList()))
.lastEntry().getValue()
.stream().map(Map.Entry::getValue)
.sorted(Comparator.comparing(s -> s.get(0)))
.map(n -> n.stream().sorted().collect(Collectors.joining(" ")))
.forEach(System.out::println);