在MapSpringWebflux中回傳Mono.error

對于匹配條件，從 code 回傳 Mono.error，但會給出編譯錯誤。我注釋掉了 //return Mono.error(new RuntimeException("User Phone Exists already"));

編譯錯誤：需要 Tyoe Mono，提供 Mono

公共 Mono getEventSlotBookWithAppointmentId(EventSlotBook eventSlotBookEntity) {

    Query query = new Query();
    query.addCriteria(
            new Criteria().andOperator(
                    Criteria.where("eventId").is(eventSlotBookEntity.getEventId()),
                    Criteria.where("eventConfigId").is(eventSlotBookEntity.getEventConfigId()),
                    Criteria.where("eventSlotId").is(eventSlotBookEntity.getEventSlotId())));

    return this.reactiveMongoTemplate.findOne(query, EventSlotBook.class)
            .map(eventSlotBookEntityFromDb -> {
                EventSlotBook eventSlotNewEntity = eventSlotBookEntityFromDb.toBuilder().build();

                if(eventSlotNewEntity.getEventUsers() != null) {
                    for(EventUser eventUserIno:eventSlotNewEntity.getEventUsers()) {
                        if(eventUserIno.getPhoneNumber().equalsIgnoreCase(eventSlotBookEntity.getEventUser().getPhoneNumber())){
                            //return Mono.error(new RuntimeException("User Phone Exists already"));
                        }
                    }
                }


                int maxTokenVal = Integer.valueOf(eventSlotNewEntity.getMaxTokenVal()).intValue()   1;
                EventUser eventUser = new EventUser(eventSlotNewEntity.getEventUser().getName(),eventSlotNewEntity.getEventUser().getPhoneNumber(),String.valueOf(maxTokenVal));
                eventSlotNewEntity.getEventUsers().add(eventUser);
                eventSlotNewEntity.setMaxTokenVal(String.valueOf(maxTokenVal));
                eventSlotNewEntity.setEventUser(eventUser);


                return eventSlotNewEntity;
                //return Mono.error(new RuntimeException("Ts"));
            })
            .switchIfEmpty(getEventSlotBook(eventSlotBookEntity));
}

方法的呼叫者：我應該處理 Mono.error 并回傳用戶已經存在的其余 API 嗎？請幫忙

public Mono<EventSlotBookRequestDto> saveEventSlotBook(Mono<EventSlotBookRequestDto> eventSlotBookRequestDtoMono){
    log.info("Start::SaveEventSlotBook");
    Mono<EventSlotBookRequestDto> eventDtoSaved =
            eventSlotBookRequestDtoMono.map(AppUtils::dtoToEntity)
                    .flatMap(eventSlotEntity -> getEventSlotBookWithAppointmentId(eventSlotEntity))
                    .doOnNext(eventSlotEntityBeforeSave -> {
                        log.info("@@@@BeforeSave::{}",eventSlotEntityBeforeSave);
                    })
                    .flatMap(eventSlotBookrepository::save)
                    .doOnNext( eventSlotBookAfterSave -> {
                        log.info("@@@@AfterSave::{}",eventSlotBookAfterSave);
                    })
                    .map(AppUtils::entityToDto);
    log.info("End::SaveEventSlotBook");
    return eventDtoSaved;
}

uj5u.com熱心網友回復：

map用于將同步函式應用于每個 item，因此您無法Mono從中回傳。要從您那里回傳錯誤，map您只需拋出一個例外，就會發出錯誤信號。作為替代方案，您可以使用handle運算子并使用SynchronousSink來發出下一個或錯誤信號。

但是在您的情況下，您需要flatMap改用，因為saveEventSlotBook回傳Mono并且應該異步轉換。

標籤：春天 单核细胞增多症 spring-webflux 反应式 通量

上一篇：JPQLSpring的全域過濾器

下一篇：SpringBoot中的DTO驗證不起作用