Как я могу объединить Mono и Flux? ⇐ JAVA
-
Гость
Как я могу объединить Mono и Flux?
Я создаю объект Flux of Product и Mono Category, который необходимо применить к продуктам, потому что все они должны быть сгруппированы в одну и ту же категорию. Я пытаюсь добавить категорию к каждому продукту следующим образом.
Продукты Flux = ProductRepository.findAllById(productCodes); Категория Mono = CategoryRepository.findById(productCodes.get(0)); Категория для всех этих продуктов должна быть установлена как: //Если бы это был список продуктов, т.е. List productList и Category, был бы //не Mono, я бы установил их так: ProductList.forEach(продукт -> product.setCategory(категория)); Поскольку соответствующие репозитории возвращают Mono и Flux соответственно, я не уверен, как это сделать, используя реактивную структуру, поскольку я новичок в этом. Может кто-нибудь показать мне, как этого добиться, используя реактив?
Я создаю объект Flux of Product и Mono Category, который необходимо применить к продуктам, потому что все они должны быть сгруппированы в одну и ту же категорию. Я пытаюсь добавить категорию к каждому продукту следующим образом.
Продукты Flux = ProductRepository.findAllById(productCodes); Категория Mono = CategoryRepository.findById(productCodes.get(0)); Категория для всех этих продуктов должна быть установлена как: //Если бы это был список продуктов, т.е. List productList и Category, был бы //не Mono, я бы установил их так: ProductList.forEach(продукт -> product.setCategory(категория)); Поскольку соответствующие репозитории возвращают Mono и Flux соответственно, я не уверен, как это сделать, используя реактивную структуру, поскольку я новичок в этом. Может кто-нибудь показать мне, как этого добиться, используя реактив?
Мобильная версия