更新 Reactor 中对象的状态

给出以下方法：

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 and 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 or Flux来自这样的事实Mono or Flux可以多次订阅。在这种情况下，突然你有一个共享资源在你的手上，它可能会导致令人费解的问题。

但如果所讨论的方法是从良好控制的上下文中调用的，那么它可能是安全的。

就你而言，flatMap确保内部发布者仅订阅一次。所以只要你only在此类 flatMap 中使用这些方法，它们可以安全地改变其输入参数（它保留在 flatmapping 函数的范围内）。