Also, another thing I experienced and I’m not sure...
# coroutines
m
Also, another thing I experienced and I’m not sure if it is expected is that some events are ignored after flattening if concurrency parameter is less that number of flattened flows. This only happens if children flows come from a broadcasted flow. The code above will print out only
Bar(value = 1)
and
bazValues
are never processed. It would have to be at least
flattenMerge(2)
to consume it