From 0d1848223e2ff4d40a82b12224bcb4485cc09176 Mon Sep 17 00:00:00 2001 From: z0w02ji Date: Wed, 18 Nov 2020 20:05:59 -0500 Subject: [PATCH] format --- opentelemetry/src/sdk/trace/span_processor.rs | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/opentelemetry/src/sdk/trace/span_processor.rs b/opentelemetry/src/sdk/trace/span_processor.rs index 2c3fedc879..0810bfd1aa 100644 --- a/opentelemetry/src/sdk/trace/span_processor.rs +++ b/opentelemetry/src/sdk/trace/span_processor.rs @@ -277,9 +277,8 @@ impl BatchSpanProcessor { } // Span batch interval time reached or a force flush has been invoked, export current spans. BatchMessage::Flush(Some(ch)) => { - let mut results = Vec::with_capacity( - spans.len() / config.max_export_batch_size + 1, - ); + let mut results = + Vec::with_capacity(spans.len() / config.max_export_batch_size + 1); while !spans.is_empty() { let batch = spans.split_off( spans.len().saturating_sub(config.max_export_batch_size), @@ -315,9 +314,8 @@ impl BatchSpanProcessor { } // Stream has terminated or processor is shutdown, return to finish execution. BatchMessage::Shutdown(ch) => { - let mut results = Vec::with_capacity( - spans.len() / config.max_export_batch_size + 1, - ); + let mut results = + Vec::with_capacity(spans.len() / config.max_export_batch_size + 1); while !spans.is_empty() { let batch = spans.split_off( spans.len().saturating_sub(config.max_export_batch_size),