Retrofit does not support Flow. So if I need to merge concurrent requests using 'flatMapMerge' what is the right way to do this?

You don't need

Flow

for this.

Also, make sure to wrap these in a local

coroutineScope { … }

and handle errors around it.

Flow

has great API and I need

ConflatedBroadcastChannel

for some reasons. What i did:

flowOf(StreamType.values().asFlow()
                        .flatMapMerge(10) { stream ->
                            flowOf(stream to async { apiService.getCurrentInfo(stream.path) })
                        }
                        .map { Pair(it.first, it.second.await()) }
                        .fold(mutableMapOf(), { map: MutableMap<StreamType, ContentMetadataDto>, pair: Pair<StreamType, ContentMetadataDto> ->
                            map.apply { put(pair.first, pair.second) }
                        }))
                        .onEach { map ->
                            contentMetadata.send(map)
                        }
                        .catch {
                            emit(StreamType.values().map { it to ContentMetadataDto.NO_DATA }.toMap(mutableMapOf()))
                        }
                        .collect {
                            contentMetadata.send(it)
                        }

I think you can replace the first

flowOf

with

StreamType.values().associateWith { stream -> async { apiService.getCurrentInfo(stream.path) } }.mapValues { it.second.await() }

(I'm not sure, it's hard to read).

yeap, but this works fine - thank you)

Also you can use

associateWith