Javier
myFlow.take(4).toList() // [A, B, C, D] myFlow.test { expectItem() // should be A but it mixed with next emissions cancelAndIgnoreRemainingEvents() }