Как мне вернуть Mono после выполнения FluC onComplete? - PullRequest
Новая
       33

Как мне вернуть Mono после выполнения FluC onComplete?

0 голосов
/ 22 апреля 2020

Я пытаюсь сохранить набор категорий. Когда все категории сохранены, установите категории продуктов для него. Затем верните товар. Пока мне удалось это сделать. 

public Mono<Product> save(Product product) {
    final Set<Category> categories = product.getCategories();
    Set<Category> _categorySet = new HashSet<>();
    Mono<Product> _product;
    for (Category category : categories) {
        final Mono<Category> save = categoryService.save(category);
        save.subscribe(_categorySet::add,null,()->{
            product.setCategories(_categorySet);
            repository.save(product);
        });
    }
}

Как вернуть товар после его сохранения, не полагаясь на block()? Я не могу найти источник, чтобы изучить эти вещи. Может кто-нибудь указать мне на хорошие материалы.

1 Ответ

2 голосов
/ 22 апреля 2020

не блокируйте цепочку webflux вручную. попробуйте использовать этот код. 

public Mono<Product> save(Product product) {

    final Set<Category> categories = product.getCategories();
    return Flux.fromIterable(categories)
            .flatMap(categoryService::save)
            .collect(Collectors.toSet())
            .flatMap(categorySet -> { // use `flatMap` if repository.save(product); returns `Mono<Product>`. or else use `map` if repository.save(product); returns `Product`
                product.setCategories(categorySet);
                return repository.save(product);
            });
}
...