Skip to content

Commit

Permalink
Fix some lints
Browse files Browse the repository at this point in the history
  • Loading branch information
aumetra committed Jul 10, 2024
1 parent 0664b64 commit 75b3259
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion opentelemetry-sdk/src/logs/log_emitter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -312,7 +312,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 {
Expand Down
2 changes: 1 addition & 1 deletion opentelemetry-sdk/src/metrics/periodic_reader.rs
Original file line number Diff line number Diff line change
Expand Up @@ -291,7 +291,7 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
true
}

async fn run(mut self, mut messages: impl Unpin + FusedStream<Item = Message>) {
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;
Expand Down
2 changes: 1 addition & 1 deletion opentelemetry-sdk/src/trace/span_processor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -422,7 +422,7 @@ impl<R: RuntimeChannel> BatchSpanProcessorInternal<R> {
})
}

async fn run(mut self, mut messages: impl Unpin + FusedStream<Item = BatchMessage>) {
async fn run(mut self, mut messages: impl FusedStream<Item = BatchMessage> + Unpin) {
loop {
select! {
// FuturesUnordered implements Fuse intelligently such that it
Expand Down
2 changes: 1 addition & 1 deletion opentelemetry-zipkin/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 75b3259

Please sign in to comment.