Previously, when output was printed it was output inside of a .flatMap() invocation. Because flatMap can be parallelized and handled out of order, there was no guarantee that the output would be printed in the order it was received. This change updates that call to print the output in .concatMap() which guarantees a consistent ordering.
Previously, when output was printed it was output inside of a
.flatMap()invocation. Because flatMap can be parallelized and handled out of order, there was no guarantee that the output would be printed in the order it was received. This change updates that call to print the output in.concatMap()which guarantees a consistent ordering.