如何从 Flux 生成 Mono<Map<Map<List>>

Question

我在Flux.<Response>fromIterable(responses) 的回复下方有一个回复表单。我想将其转换为地图的单声道，如下所示：

Mono>>> collectMap = ?

其中 company 是第一个键，将生成另一个响应图，其中 category 为键。

List< Response> responses = new ArrayList(){
            {
                add(Response.builder().company("Samsung").category("Tab").price("$2000").itemName("Note").build());
                add(Response.builder().company("Samsung").category("Phone").price("$2000").itemName("S9").build());
                add(Response.builder().company("Samsung").category("Phone").price("$1000").itemName("S8").build());
                add(Response.builder().company("Iphone").category("Phone").price("$5000").itemName("Iphone8").build());
                add(Response.builder().company("Iphone").category("Tab").price("$5000").itemName("Tab").build());
            }
        };

虽然我能够实现如下的初始地图

Mono<Map<String, Collection<Response>>> collect = Flux.<Response>fromIterable( responses )
                .collectMultimap( Response::getCompany );

有人知道我如何在这里实现我的目标吗？

Answer 1

我认为collectMultiMap 或collectMap 在这种情况下不会直接帮助您：

1. collectMultiMap（及其重载）只能返回 Map<T, Collection<V>，这显然与您想要的不同。当然，您可以处理 O(n) 复杂度的结果值集（即映射的 Collection<V> 部分）。

2. 另一方面，如果您提供值函数，collectMap（及其重载）看起来更有希望。但是，您无权访问其他 V 对象，这将禁止您构建 Collection<V>。

我想出的解决方案是使用reduce；虽然返回类型是： Mono<Map<String, Map<String, List<Response>>>>（注意List<V> 而不是Collection<V>）

return Flux.<Response>fromIterable( responses )
           .reduce(new HashMap<>(), (map, user) -> {
                map.getOrDefault(user.getId(), new HashMap<>())
                        .getOrDefault(user.getEmail(), new ArrayList<>())
                        .add(user);
                return map;
            });

reduce 中HashMap 的完整类型是HashMap<String, Map<String, List<AppUser>>>，幸运的是Java 可以从方法的返回类型或分配变量的类型推断出这一点。