|
1 | 1 | use crate::measurements::format_bytes; |
2 | 2 | use crate::measurements::log_measurements; |
3 | | -use crate::measurements::Measurement; |
4 | 3 | use crate::measurements::LatencyMeasurement; |
| 4 | +use crate::measurements::Measurement; |
5 | 5 | use crate::progress::print_progress; |
6 | 6 | use crate::OutputFormat; |
7 | 7 | use crate::SpeedTestCLIOptions; |
@@ -94,18 +94,25 @@ pub fn speed_test(client: Client, options: SpeedTestCLIOptions) -> Vec<Measureme |
94 | 94 | if options.output_format == OutputFormat::StdOut { |
95 | 95 | println!("{metadata}"); |
96 | 96 | } |
97 | | - let (latency_measurements, avg_latency) = run_latency_test(&client, options.nr_latency_tests, options.output_format); |
| 97 | + let (latency_measurements, avg_latency) = |
| 98 | + run_latency_test(&client, options.nr_latency_tests, options.output_format); |
98 | 99 | let latency_measurement = if !latency_measurements.is_empty() { |
99 | 100 | Some(LatencyMeasurement { |
100 | 101 | avg_latency_ms: avg_latency, |
101 | | - min_latency_ms: latency_measurements.iter().copied().fold(f64::INFINITY, f64::min), |
102 | | - max_latency_ms: latency_measurements.iter().copied().fold(f64::NEG_INFINITY, f64::max), |
| 102 | + min_latency_ms: latency_measurements |
| 103 | + .iter() |
| 104 | + .copied() |
| 105 | + .fold(f64::INFINITY, f64::min), |
| 106 | + max_latency_ms: latency_measurements |
| 107 | + .iter() |
| 108 | + .copied() |
| 109 | + .fold(f64::NEG_INFINITY, f64::max), |
103 | 110 | latency_measurements, |
104 | 111 | }) |
105 | 112 | } else { |
106 | 113 | None |
107 | 114 | }; |
108 | | - |
| 115 | + |
109 | 116 | let payload_sizes = PayloadSize::sizes_from_max(options.max_payload_size.clone()); |
110 | 117 | let mut measurements = Vec::new(); |
111 | 118 |
|
|
0 commit comments