jbnizet
03/08/2020, 10:02 PMFlux.flatMapSequential()
, i.e. a flattenMerge(), but which would emit the values in the initial order of the merged flows. Any idea? I find such an operator quite useful, for example when you want to send HTTP requests in parallel, but with a limited concurrency, and still want to process the responses as if they had been sent sequentially.octylFractal
03/08/2020, 10:21 PMoctylFractal
03/08/2020, 10:23 PMoctylFractal
03/08/2020, 10:26 PMChannel.UNLIMITED
capacity, meaning that you could potentially have a lot of memory build up. you could change it to take a capacity parameter or two, depending on if you want to cap the number of active flows, or the number of items held in the backlogjbnizet
03/08/2020, 10:47 PMjbnizet
03/08/2020, 10:48 PMbdawg.io
03/09/2020, 3:42 AMflow.flatMapConcat { it }
?octylFractal
03/09/2020, 3:43 AMflatMapConcat
in this context, is that if the Flow
is cold, it won't run things in paralleloctylFractal
03/09/2020, 3:44 AM