通量结果与单点结果的合并

Question

public interface GroupRepository {
       Mono<GroupModel> getGroup(Long groupId);
}

public interface UserRepository {
       Flux<User> getUsers(Set<Long> userIds);   
}

Mono<GroupModel> groupMono = getGroup(groupId);
Flux<User> userFlux = getUsers(Set<Long> users);
//run above instrtuction in parallel and associate user to group.

现在我想实现的是：

如何组合来自UserFlux的响应，并使用类似group.addUsers（userfromFlux）的内容将这些用户与该组关联起来。

有人能帮助如何组合来自userFlux和GroupMono的结果吗。我想我使用了像Zip这样的东西，但它会从源代码进行一对一的映射。在我的例子中，我需要做1到N映射。这里我有一个组，但多个用户，我需要添加到该组。返回mono ，然后将zip运算符与mono一起使用，并提供这里提到的组合器
public static flux zip（publisher<？extends T1>source1,publisher<？extends T2>source2,final bifunction<？super T1,？super T2,？extends o>combinator) 是个好主意吗？

Answer 1

这个1到N映射听起来类似于我在这里回答的一个问题：

你可以flux.zip一个mono和一个flux并对每个flux值重复mono值吗？

万一那个链接掉了，答案又来了。我不认为这种方法会有很好的性能，因为单声道每次都会被重新计算。为了获得更好的性能，如果您的单声道被一个缓慢的操作所包围，最好有一些缓存层。

 // a flux that contains 6 elements.
 final Flux<Integer> userIds = Flux.fromIterable(List.of(1,2,3,4,5,6));

 // a mono of 1 element.
 final Mono<String> groupLabel = Mono.just("someGroupLabel");

 // wrong way - this will only emit 1 event 
 final Flux<Tuple2<Integer, String>> wrongWayOfZippingFluxToMono = userIds
         .zipWith(groupLabel);

 // you'll see that onNext() is only called once, 
 //     emitting 1 item from the mono and first item from the flux.
 wrongWayOfZippingFluxToMono
         .log()
         .subscribe();

 // this is how to zip up the flux and mono how you'd want, 
 //     such that every time the flux emits, the mono emits. 
 final Flux<Tuple2<Integer, String>> correctWayOfZippingFluxToMono = userIds
         .flatMap(userId -> Mono.just(userId)
                 .zipWith(groupLabel));

 // you'll see that onNext() is called 6 times here, as desired. 
 correctWayOfZippingFluxToMono
         .log()
         .subscribe();