Не могу понять почему у меня не сохраняются записи в

Question

Не могу понять почему у меня не сохраняются записи в

базу при использовании webflux + r2dbc

@PostMapping
public Mono<? extends BaseResponse> setUserPreference(@AuthenticationPrincipal UserDetail userDetail,
@RequestBody List<UserPreferenceRequest> request) {

return userService.getByUserDetails(userDetail)
.doOnNext(user -> request.forEach(pref -> userPreferenceService.setUserPreference(user, pref.getType(), pref.getValue())))
.map(none -> OkResponse.ok());
}

------------------
public Mono<UserPreference> setUserPreference(User user, String type, String value) {
return userPreferenceRepository.findAllByUserIdAndType(user.getId(), type)
.filter(userPreference -> type.equalsIgnoreCase(userPreference.getValue()))
.flatMap(userPreference -> {
userPreference.setValue(value);
return userPreferenceRepository.save(userPreference);
})
.switchIfEmpty(userPreferenceRepository.save(UserPreference.builder()
.user(user)
.type(type)
.value(value)
.build()));

}

#backend #java #programming #russian

0

16.03.2021

1 ответов

2 просмотра

Антон Смолин · Accepted Answer

Антон Смолин

doOnNext не делает подписку, если туда передается реактивное значение

0

16.03.2021

170 похожих чатов

Не могу понять почему у меня не сохраняются записи в

1 ответов

Похожие вопросы