// If the collecting scope is cancelled before this map operation,
// seems like map operation is not cancelled and throws an exception
numbersFlow.map {
    // There is an operation which throws exception
}
.flowOn(<http://Dispatchers.IO|Dispatchers.IO>)

ensureActive()