This part of code will emit the result of the request one by one. Can someone please tell me how to ...

# flow

[gts13]

This part of code will emit the result of the request one by one.
Can someone please tell me how to bunch the results of all the requests into a list?

suspend fun getOffers(
    categories: List<Category>
): Flow<Offer> = categories
    .asFlow()
    .flatMapMerge(concurrency = 20) {
        suspend { api.requestOffers(it) }.asFlow()
    }

[CLOVIS]

You should use buffer before flatMapMerge

[gts13]

I tried but doesnt work

[gts13]

suspend fun getOffers(
    categories: List<Category>
): Flow<Offer> = categories
    .asFlow()
    .buffer()
    .flatMapMerge(concurrency = 20) {
        suspend { api.requestOffers(it) }.asFlow()
    }
    .map {
       // here I still see one result, not a list of results
     }

[MR3Y]

suspend fun getOffers(
    categories: List<Category>
): Flow<Offer> = coroutineScope { 
categories
    .map { 
       async {
         api.requestOffers(it)
       }
    }.awaitAll()
}.asFlow()

[gts13]

yes that works! Thank you @MR3Y