What is the most efficient way to add a List<X> to a Flow of

List<Y>.flatMapMerge { channelFlow { send(it.toX()) } }.buffer()

while preserving concurrency?

didnt really understand this question

I have a Flow pipeline that produces X's from Y's. I have a List<X> that I want to add in the flow while keeping the flatMapMerge buffered/concurrent and anything else downstream also buffered/concurrent

Did you already figure this out? If not, at what point to do you have the

List<X>

available to add to

List<Y>.flatMapMerge { channelFlow { send(it.toX()) } }.buffer()

?