Fix some lints

Author: aumetra

opentelemetry-jaeger/src/exporter/config/collector/http_client.rs

@@ -119,6 +119,7 @@ pub(crate) mod test_http_client {
     use opentelemetry_http::{HttpClient, HttpError};
     use std::fmt::Debug;
 
+    #[allow(unused)]
     pub(crate) struct TestHttpClient;
 
     impl Debug for TestHttpClient {

opentelemetry-sdk/src/logs/log_emitter.rs

@@ -274,7 +274,7 @@ mod tests {
     use opentelemetry::{Key, KeyValue, Value};
     use std::fmt::{Debug, Formatter};
     use std::sync::atomic::AtomicU64;
-    use std::sync::{Arc, Mutex};
+    use std::sync::Mutex;
     use std::thread;
 
     struct ShutdownTestLogProcessor {

opentelemetry-sdk/src/metrics/periodic_reader.rs

@@ -9,7 +9,7 @@ use futures_util::{
     future::{self, Either},
     pin_mut,
     stream::{self, FusedStream},
-    Stream, StreamExt,
+    StreamExt,
 };
 use opentelemetry::{
     global,
@@ -290,7 +290,7 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
         true
     }
 
-    async fn run(mut self, mut messages: impl Stream<Item = Message> + Unpin + FusedStream) {
+    async fn run(mut self, mut messages: impl FusedStream<Item = Message> + Unpin) {
         while let Some(message) = messages.next().await {
             if !self.process_message(message).await {
                 break;

opentelemetry-sdk/src/metrics/pipeline.rs

@@ -165,8 +165,8 @@ impl SdkProducer for Pipeline {
                             // previous aggregation was of a different type
                             prev_agg.data = data;
                         }
-                        prev_agg.name = inst.name.clone();
-                        prev_agg.description = inst.description.clone();
+                        prev_agg.name.clone_from(&inst.name);
+                        prev_agg.description.clone_from(&inst.description);
                         prev_agg.unit = inst.unit.clone();
                     }
                     _ => continue,

opentelemetry-sdk/src/trace/span_processor.rs

@@ -42,7 +42,7 @@ use futures_util::{
     future::{self, BoxFuture, Either},
     select,
     stream::{self, FusedStream, FuturesUnordered},
-    Stream, StreamExt as _,
+    StreamExt as _,
 };
 use opentelemetry::global;
 use opentelemetry::{
@@ -399,7 +399,7 @@ impl<R: RuntimeChannel> BatchSpanProcessorInternal<R> {
         })
     }
 
-    async fn run(mut self, mut messages: impl Stream<Item = BatchMessage> + Unpin + FusedStream) {
+    async fn run(mut self, mut messages: impl FusedStream<Item = BatchMessage> + Unpin) {
         loop {
             select! {
                 // FuturesUnordered implements Fuse intelligently such that it

opentelemetry-zipkin/src/lib.rs

@@ -84,7 +84,7 @@
 //! [`ZipkinPipelineBuilder`] docs for details of each option.
 //!
 //!
-//! ```no_run,ignore
+//! ```no_run
 //! use opentelemetry::{global, KeyValue, trace::Tracer};
 //! use opentelemetry_sdk::{trace::{self, RandomIdGenerator, Sampler}, Resource};
 //! use opentelemetry_sdk::export::trace::ExportResult;