Java被动获取ServerRequest主体，运行存储库并返回flux

Question

我试图从服务器请求中获取HttpRequest主体中的“用户”主体。我使用路由器功能来实现这一点。这个“用户”键包含用户列表。

之后，我需要提取这个用户列表，从存储库中获取流量，然后返回前端。我怎样才能做到这一点？

@Repository
public interface UserRepository extends ReactiveCrudRepository<User, Integer> {
    Flux<Account> findByUserIn(List userList);
}

如何修改下面的代码使其工作？

    public Mono<ServerResponse> getUserList(ServerRequest request) {

        Flux<User> users = request.bodyToMono(String.class).doOnSuccess(x -> {
            JSONObject jObject = new JSONObject(x);
            List userList= jObject.getJSONArray("users").toList();
            userRepository.findByUserIn(userList);
        })
        return ServerResponse.ok().body(users, Repo.class);
    }

Answer 1

我找到了答案，因为几个拼写错误而卡住了，多亏Toerktumlare指出了答案。我需要使用flatMapMany。

public Mono<ServerResponse> getUserList(ServerRequest request) {

    Flux<User> results = request.bodyToMono(String.class)
            .flatMapMany(x -> {
                JSONObject req = new JSONObject(x);
                List userList = req.getJSONArray("users").toList();
                return userRepository.findByUserIn(userList);
            });
    return ServerResponse.ok().body(results, User.class);
}