Iterate over a list of list and call a method for every item with Quarkus reactive

[dkoci]

Hi.
I need some help with reactive Quarkus with Panache. I have a method that lists all items in a table from the database and returns Uni. Each Form item contains a list of equipmentCollection (List). I would like to iterate over all the equipmentCollection items, and if equipment.type == "output", I want to call the getQuantity() method, which retrieves a value from another table in the database and updates equipment.quantity to the value returned by getQuantity().

Something like (I know my code is not ok. I am stuck and dont know how to handle it the right way)

`
public Uni<List

> listAll(Integer page, Integer size) {

PanacheQuery<Form> query = Form.<Form>findAll(Sort.descending("idForm"));

if (page != null && size != null) {
    query = query.page(Page.of(page, size));
}

return query.list().onItem().transform(formList -> {

    formList.forEach(form -> {

        for (Equipment equipment : form.formCollection) {

            Uni<FormEquipment> fe = getQuantity(form.idForm, equipment.idEquipment;
            equipment.quantity = fe.quantity;
        }
    });

    return formList;
});

}
`

[cescoffier]

\CC @jponge

[jponge]

You might check https://smallrye.io/smallrye-mutiny/latest/guides/branching/ to combine some branching logic + async I/O in a pipeline.

[dkoci]

Thank you. I'm very interested in reactive Java programming, so I'll definitely check it.