无法返回Mono<Compliance>

Question

我尝试从DB中检索Mono，然后根据一个条件过滤PortCall对象中的遵从性列表，最后返回一个遵从性或Mono

下面是我的Mongo DB查询

@Query("{vesselCode : ?0, arrivalVoyageCode: ?1}")
Mono<PortCall> findDeadlineTimestamp(String vesselCode, String arrivalVoyageCode);

下面是在ServiceImpl中检索单声道的用法

Mono<Compliance> cmp = portCallRepository.findDeadlineTimestamp(arrivalVoyageCode, vesselCode)
            .doOnNext(p->p.getCompliance().stream()
            .filter(c->c.getId().equalsIgnoreCase(compId))).subscribe();

Answer 1

您应该使用Reactor的运算符，而不是Java 8 streams。

这样做的预期方法是实际使用filter和map运算符

Mono<Compliance> getCompliance() {
    return portCallRepository.findDeadlineTimestamp(arrivalVoyageCode, vesselCode)
            .map(e -> e.getCompliance())
            .filter(c -> c.getId().equalsIgnoreCase(compId));
}

然后，调用者将订阅：

getCompliance().subscribe()