网络客户端调用后未调用 FlatMap

如何解决网络客户端调用后未调用 FlatMap

我在 Spring Webflux 的 @Service 中有这个函数，它被一个朋友列表调用，以了解是否每个人都加入了一个组。如果某些朋友没有群组，此方法会调用一个 API 来获取其用户信息，然后调用另一个 API 将这些人标记为 false。

@Service
...
  public Flux<Boolean> checkUserHaveGroup(final List<String> friends) {
    MatchOperation match1 = Aggregation.match(Criteria.where("friends").in(friends).and("status").is("ACTIVE"));
    UnwindOperation unwind1 = Aggregation.unwind("friends");
    MatchOperation match2 = Aggregation.match(Criteria.where("friends").in(friends));
    GroupOperation group1 = Aggregation.group("friends");

    TypedAggregation<Group> a = Aggregation.newAggregation(
        Group.class,match1,unwind1,match2,group1);

    return this.reactiveMongoTemplate.aggregate(a,FriendInGroup.class)
        .map(friendInGroup -> friendInGroup.id)
        .collectList()
        .map(users -> haveNoGroupsList(users,friends))
        .flatMapMany(noGroupUsers -> {
          return Flux.fromIterable(noGroupUsers)
              .flatMap(pn -> crmService.deleteAttribute(pn,"joinedAGroup"));
        });
  }

(this method get the user information)
...
public Mono<UserInfo> userInfoById(final String userId) {

    return webClient.get()
        .uri(uriBuilder -> uriBuilder.path(constants.getByIdPath() + "/{id}")
            .build(userId))
        .header("auth",tokenService.token())
        .exchange()
        .flatMap(response -> {
          Mono<UserInfo> responseMono;

          if (response.statusCode().equals(HttpStatus.UNAUTHORIZED)) {
            responseMono = Mono.error(new UnauthorizedException());
          } else if (response.statusCode().equals(HttpStatus.OK)) {
            responseMono = response.bodyToMono(UserInfoResponse.class)
                .flatMap(uir -> Mono.just(uir.getData()));
          } else {
            responseMono = Mono.error(new UnhandledException());
          }

          return responseMono;
        });

  }

...
  private Mono<UserInfo> getUserInfo(String userId) {
    return userInfoAdapter.userInfoById(userId);
  }


...

  public Mono<Boolean> deleteAttribute(final String userId,final String attribute) {
    return getUserInfo(userId) <<<<< here we get the users info
        .flatMap(ui -> crmDeleteAttribute(ui,attribute)); <<<< this call is never done.
  }

...


 public Mono<Boolean> crmDeleteAttribute(final UserInfo user,final String attribute) {

    return webClient.delete()
        .uri(uriBuilder -> uriBuilder
            .path(contants.path())
            .build(user.getId(),attribute))
        .header("auth",tokenService.token())
        .exchange().flatMap(response -> {
          if (response.statusCode().equals(HttpStatus.OK)) {
            return Mono.just(Boolean.TRUE);
          }
          if (response.statusCode().equals(HttpStatus.BAD_REQUEST)) {
            return Mono.error(CrmServiceBadRequestException::new);
          }
          if (response.statusCode().equals(HttpStatus.UNAUTHORIZED)) {
            return Mono.error(CrmServiceUnauthorizedException::new);
          }
          return Mono.error(CrmServiceUnhandledException::new);
        });
  }

在API上获取用户信息后，无论我做什么，都不会调用分配标签的API。我可以在调试器终端中看到对 UserInfo API 的调用已完成，但之后，应用程序返回到控制器。有人可以指出我做错了什么吗？

欢迎任何帮助。

谢谢！