natario1
03/20/2021, 6:37 PMcombine(flow1, flow2, ..., flowN, transform)
that does not wait for all flows to emit the first value? I'd happily receive a smaller array if some flow does not have a value yet.elizarov
03/20/2021, 8:54 PMonStart { emit(null) }
on each on the source flows to have them immediately emit a null. What are you trying to achieve, though?natario1
03/20/2021, 9:08 PMList<Flow<T>>
where each flow retrieves a single T
item. Retrieval is very expensive. Then I want a Flow<List<T>>
including all items that satisfy a certain condition, so I'm using combine(*flows) { it.filter(condition) }
. Works but, waits for all flows, while I'd like to receive incomplete results as well.natario1
03/20/2021, 9:10 PMonStart { emit(null) }
equivalent to flow { emit(null); emitAll(flow) }
?elizarov
03/21/2021, 7:21 AMlist.asFlow().flattenMerge(list.size).filter { … }
natario1
03/21/2021, 11:29 AM