更新反应堆中对象的状态

给出以下方法：

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函数的作用域中)。