What is the most efficient way to add a List<X&...
# flow
s
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?
n
didnt really understand this question
s
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
j
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()
?