https://kotlinlang.org logo
#flow
Title
# flow
s

Sam Stone

04/18/2022, 4:02 AM
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

Nick Williams

04/19/2022, 8:25 AM
didnt really understand this question
s

Sam Stone

04/19/2022, 3:56 PM
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

julian

04/24/2022, 5:44 PM
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()
?
2 Views