PushVsPullBenchmark.kt

@Warmup(iterations = 7, time = 1)
@Measurement(iterations = 5, time = 1)
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MILLISECONDS)
@State(Scope.Benchmark)
@Fork(2)
open class PushVsPullBenchmark {

    private val source = flow {
        repeat(100_000) { emit(it) }
    }

    @Benchmark
    fun pull() = runBlocking {
        source.onEach { require(it >= 0) }.collect()
    }

    @Benchmark
    fun push() = runBlocking {
        source.iterate {
            while (hasNext()) {
                require(next() >= 0)
            }
        }
    }
}

Benchmark                 Mode  Cnt   Score   Error  Units
PushVsPullBenchmark.pull  avgt   10   2.295 ± 0.315  ms/op
PushVsPullBenchmark.push  avgt   10  67.274 ± 3.652  ms/op