我有一个返回Flux<SensorData>的方法，让我们假设SensorData有一个字段measure: Integer。
我想计算整个通量的平均值。如何做呢？
val sensorFlux: Flux<SensorData> = sensorRepository.findAll()
...
最佳答案
Mono<Double> average = sensorFlux.collect(Collectors.averagingInt(SensorData::getMeasure))