本文介紹了更新反應堆中對象的狀態的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
給出以下方法：
private Mono<UserProfileUpdate> upsertUserIdentifier(UserProfileUpdate profileUpdate, String id){
return userIdentifierRepository.findUserIdentifier(id)
.switchIfEmpty(Mono.defer(() -> {
profileUpdate.setNewUser(true);
return createProfileIdentifier(profileUpdate.getType(), id);
}))
.map(userIdentifier -> {
profileUpdate.setProfileId(userIdentifier.getProfileId());
return profileUpdate;
});
}
switchIfEmpty和map運算符使profileUpdate對象發生突變。在switchIfEmpty運算符中進行變異是否安全？關于map，如果我理解正確的話，這是不安全的，對象profileUpdate必須是不可變的，對嗎？例如：
private Mono<UserProfileUpdate> upsertUserIdentifier(UserProfileUpdate profileUpdate, String id){
return userIdentifierRepository.findUserIdentifier(id)
.switchIfEmpty(Mono.defer(() -> {
profileUpdate.setNewUser(true);
return createProfileIdentifier(profileUpdate.getType(), id);
}))
.map(userIdentifier -> profileUpdate.withProfileId(userIdentifier.getProfileId()));
}
在鏈的后面，另一個方法改變對象：
public Mono<UserProfileUpdate> transform(UserProfileUpdate profUpdate) {
if (profUpdate.isNewUser()) {
profUpdate.getAttributesToSet().putAll(profUpdate.getAttributesToSim());
} else if (!profUpdate.getAttributesToSim().isEmpty()) {
return userProfileRepository.findUserProfileById(profUpdate.getProfileId())
.map(profile -> {
profUpdate.getAttributesToSet().putAll(
collectMissingAttributes(profUpdate.getAttributesToSim(), profile.getAttributes().keySet()));
return profUpdate;
});
}
return Mono.just(profUpdate);
}
上述方法調用方式如下：
Mono.just(update)
.flatMap(update -> upsertUserIdentifier(update, id))
.flatMap(this::transform)
推薦答案
回答模糊，但…視情況而定！
在返回的Mono或Flux中突變輸入參數的危險來自于所述Mono或Flux可以被多次訂閱。在這種情況下，您手中突然有一個共享資源，這可能會導致令人費解的問題。
但如果從受控良好的上下文中調用有問題的方法，則它可以是安全的。
在您的例子中，flatMap確保內部發布者只訂閱一次。因此，只要您僅在此類PlatMap中使用這些方法，它們就可以安全地更改其輸入參數(它保留在Platmap函數的作用域中)。
這篇關于更新反應堆中對象的狀態的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
