如何用单条Java Stream流水线实现ItemRequest按backingService分组转Map

直接通过嵌套Stream收集器即可将两步逻辑合并为单条流水线，无需中间变量存储分组后的ItemId列表，实现如下：

import java.util.Map;
import java.util.stream.Collectors;

Map<String,ItemRequest> breakItemRequestAsPerBackingService(ItemRequest originalItemRequest ){
    return originalItemRequest
            .getItemIds()
            .stream()
            .collect(Collectors.groupingBy(
                    itemId -> itemId.getItemType().getBackingService(),
                    Collectors.collectingAndThen(
                            Collectors.toList(),
                            itemIds -> new ItemRequest(originalItemRequest.getAction(), itemIds)
                    )
            ));
}

如果静态导入Collectors下的方法，代码可以更简洁：

import static java.util.stream.Collectors.*;

Map<String,ItemRequest> breakItemRequestAsPerBackingService(ItemRequest originalItemRequest ){
    return originalItemRequest
            .getItemIds()
            .stream()
            .collect(groupingBy(
                    itemId -> itemId.getItemType().getBackingService(),
                    collectingAndThen(toList(), itemIds -> new ItemRequest(originalItemRequest.getAction(), itemIds))
            ));
}

实现逻辑说明 #

• 核心是利用Collectors.groupingBy的第二个下游收集器参数，直接对同一分组的元素做后续转换
• 第一层按backingService完成分组，第二层先用toList()收集同组的所有ItemId，再通过collectingAndThen将List包装为新的ItemRequest对象，复用原请求的action字段
• 该实现和你原有两段式Stream的处理结果完全等价，没有逻辑差异

内容的提问来源于stack exchange，提问作者ThrowableException