Cargo formatting linter fixes

Author: Puffy1215

opentelemetry-sdk/src/trace/span.rs

@@ -16,7 +16,7 @@ use std::time::SystemTime;
 
 /// Single operation within a trace.
 #[derive(Debug)]
-pub struct Span<> {
+pub struct Span {
     span_context: SpanContext,
     data: Option<SpanData>,
     tracer: crate::trace::SdkTracer,
@@ -200,21 +200,19 @@ impl Span {
     fn ensure_ended_and_exported(&mut self, timestamp: Option<SystemTime>) {
         // skip if data has already been exported
         let mut data = match self.data.take() {
-            Some(data) => {
-                crate::trace::SpanData {
-                    span_context: self.span_context.clone(),
-                    parent_span_id: data.parent_span_id,
-                    span_kind: data.span_kind,
-                    name: data.name,
-                    start_time: data.start_time,
-                    end_time: data.end_time,
-                    attributes: data.attributes,
-                    dropped_attributes_count: data.dropped_attributes_count,
-                    events: data.events,
-                    links: data.links,
-                    status: data.status,
-                    instrumentation_scope: self.tracer.instrumentation_scope().clone(),
-                }
+            Some(data) => crate::trace::SpanData {
+                span_context: self.span_context.clone(),
+                parent_span_id: data.parent_span_id,
+                span_kind: data.span_kind,
+                name: data.name,
+                start_time: data.start_time,
+                end_time: data.end_time,
+                attributes: data.attributes,
+                dropped_attributes_count: data.dropped_attributes_count,
+                events: data.events,
+                links: data.links,
+                status: data.status,
+                instrumentation_scope: self.tracer.instrumentation_scope().clone(),
             },
             None => return,
         };
@@ -234,9 +232,7 @@ impl Span {
 
         match provider.span_processors() {
             [] => {}
-            [processor] => {
-                processor.on_end(&mut data)
-            }
+            [processor] => processor.on_end(&mut data),
             processors => {
                 for processor in processors {
                     processor.on_end(&mut data);

opentelemetry-sdk/src/trace/span_processor.rs

@@ -460,7 +460,7 @@ impl BatchSpanProcessor {
         E: SpanExporter + Send + Sync + 'static,
     {
         // Get upto `max_export_batch_size` amount of spans from the channel and push them to the span vec
-        while let Ok(span)  = spans_receiver.try_recv() {
+        while let Ok(span) = spans_receiver.try_recv() {
             spans.push(span);
             if spans.len() == config.max_export_batch_size {
                 break;

opentelemetry-sdk/src/trace/span_processor_with_async_runtime.rs

@@ -107,7 +107,9 @@ impl<R: RuntimeChannel> SpanProcessor for BatchSpanProcessor<R> {
             return;
         }
 
-        let result = self.message_sender.try_send(BatchMessage::ExportSpan(span.clone()));
+        let result = self
+            .message_sender
+            .try_send(BatchMessage::ExportSpan(span.clone()));
 
         // If the queue is full, and we can't buffer a span
         if result.is_err() {