操纵单粒子和通量变换

Question

我正在使用Spring 5 webflux和ReactiveMongorPositories。假设我有两个系列“竞赛”和“竞赛参与”：

    Race : {
    "_id" : "ID",
    "name" : "Name"
    }

    RaceParticipation : {
    "_id" : "ID",
    "userId" : "ID",
    "raceId" : "ID"
    }

我需要找到一个特定用户参与的比赛页面。

我使用的解决方案是调用raceReportationRepository.findByUserId（"userId"，PageRequest.of（0,10））这将返回一个Flux

以下是一个片段：

Flux<Race> findUserRaces(String userId, int page){
    return raceParticipationRepository.findByUserId(userId, status,
                PageRequest.of(page, 6))
            .collectList()
            .map(list -> list.stream()
                    .map(ParticipationRepository::getRaceId)
                    .collect(Collectors.toList()))
            .flatMap(list -> raceRepository.findAllById(list));
}

这段代码无法编译<代码>“所需流量

知道我错过了什么或者我该怎么做吗？




Answer 1

您的问题是CollectList（）部分，因为它从您的Flux中生成了一个Mono，这显然是您不想要的——您在收集后立即从列表中生成了一个流。这里应该做同样的事情，再加上将Mono映射到一个带有平面图的Flux：

raceParticipationRepository.findByUserId(userId, status,
            PageRequest.of(page, 6))
      .map(ParticipationRepository::getRaceId)
                .collectList(Collectors.toList()) // returns Mono<List>
      .flatMapMany(list -> raceRepository.findAllById(list)); // Mono -> Flux again