Benchmark.kt

val benchmarkList = List<ProducerConsumerCoroutinesOnlyBenchmark>(100) { ProducerConsumerCoroutinesOnlyBenchmark() }

launch {
    val resultList = benchmarkList.map {
        it.startBenchmark()
    }
    val resultReduced = resultList.reduce {sum, element ->
        ProducerConsumerCoroutinesOnlyBenchmark.Result(sum.executionTime + element.executionTime, sum.numOfReceivedMessages + element.numOfReceivedMessages)
    }
    Log.d("FragmentCoroutinesDemo", "Result not reduced " + resultReduced.executionTime + "ms")
    onBenchmarkCompleted(ProducerConsumerCoroutinesOnlyBenchmark.Result(resultReduced.executionTime / 100, resultReduced.numOfReceivedMessages / 100))
}