Cancel Multi stream

[MimiXav]

I am using a Multi for an event stream in a project. I call a remote service on the network, I loop on a Multi to call this network service, but at the first failure (sometimes the service is down so for each item, I will have the same error), and I want to cancel the stream at the first failure, I don't know how to do that?
Here a snippet of my code:
List myList = Stream.of("s1", "s2", "s3").collect(Collectors.toList());
Multi multi = Multi.createFrom().items(myList.stream());
multi.subscribe()
.with(s -> {
Uni uni = networkService(s);
uni
.subscribe()
.with(s2 -> {
logger.info("ok");
}, failure -> {
// At the first failure I want exit the stream and not continue.
logger.error("🔥 failure", failure.getMessage());
});

Thanks for any help

Regards

[cescoffier]

Hello,

What about:

multi.onItem().transformToUniAndConcatenate(x -> callService(x))
.subscribe().with(...)

You can decide if you prefer concatenate or merge, depending on the behavior you want.

[MimiXav]

Hi Clement,

Tanks a lot, it's exactly what I want.
Regards