使用反应式webclient递归调用Mono函数

Question

需要从单声道递归调用单声道以获得完整的项目。我有一个Pojo项目，在这里我将传递根ID，并尝试从另一个服务获得项目。我写我的服务使用sprignwebFlow。所以我正在使用webClient调用服务并返回Mono

另一项服务将提供该项目及其直接子项。因此，我的要求是，当我传递根id时，我将获得根项及其直接子项，根将LM类型项作为子项。

获得Root项目后，我需要收集所有的LM id，并再次调用每个LM id的ItemService，并将它们设置回root项目。

这是我的代码。首先我的RootItem返回，然后获取LM项的调用正在订阅。我想首先获取所有LM项并将它们设置为root，然后用新的LM项响应root项。

String itemId,
String ItemName,
List<Item> items
ItemType itemType

}

Enum ItemType {

LM,ROOT,LEAF

}


getItem(itemId) {

// Returns Mono<Item> by calling anthoer service which gives me Item . Here I am using Reactive webclient to call other service.

}

getFullItem(itemId) {

    return getItem(itemId)
        .flatMap(mainItem -> {
            Predicate<Item> LM_Prdicate = p -> p.getItemType().equals(LM);
            // get the LM's from main item. at this point the LM items will not have child
            //we need to get the LM item indvidually to get its child and set back to main item.
            List<Item> LMSwihtouchild = mainItem.getItems().stream().filter(LM_Prdicate).collect(Collectors.toList()); 

            LMSwihtouchild.forEach(lmWihtoutChild -> {
                getItem(lmWihtoutChild.getId()) // here I am calling recursively to get the LM Item so that it will come with children
                .flatMap(lmWithChildren -> {
                    mainItem.getItems().removeIf(item -> item.getId().equals(lmWihtoutChild.getId())); // removing the LM item with out child from main item
                    mainItem.getContentItems().add(lmWithChildren); //Adding LM item with Children
                    return Mono.just(mainItem);
                })
                .subscribe()             
            });
            return Mono.just(mainItem); // This retruning to as  response before calling and getting the LM items with children.
        });
}

Answer 1

您需要制作方法链。您不应该执行。订阅（）内部。flatMap，因为它未连接到主方法链。

我通过你的例子制作了伪代码。

getFullItem(itemId) {
    return getItem(itemId)
        .flatMap(mainItem -> {
            Predicate<Item> LM_Prdicate = p -> p.getItemType().equals(LM);
            List<Item> LMSwihtouchild = mainItem.getItems().stream().filter(LM_Prdicate).collect(Collectors.toList()); 

            // make flux from List<Item>. It's connected to your method chain.
            return Flux.fromIterable(LMSwihtouchild)
                .flatMap(child -> getItem(child.getId())
                .collectList()
                .map(childList -> {
                    // merge result here
                    mainItem.getItems().removeIf(item -> item.getId().equals(lmWihtoutChild.getId()));
                    mainItem.getContentItems().add(lmWithChildren);
                    return mainItem;
                }      
            });
        });
}