remove several warnings from unused imports

runtime/console/src/aggregate.rs

@@ -7,7 +7,6 @@ use console_api::{async_ops, instrument, resources, tasks};
 use crossbeam_channel::{Receiver, TryRecvError};
 use futures_util::{FutureExt, StreamExt};
 use std::collections::HashMap;
-use std::num::NonZeroU64;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
 use std::time::{Duration, Instant};

runtime/console/src/lib.rs

@@ -1,5 +1,4 @@
 use crossbeam_channel::{Sender, TrySendError};
-use std::borrow::Borrow;
 use std::cell::RefCell;
 use std::net::IpAddr;
 use std::sync::atomic::{AtomicUsize, Ordering};
@@ -9,7 +8,7 @@ use thread_local::ThreadLocal;
 use tracing::span;
 use tracing_core::span::Attributes;
 use tracing_core::{Interest, Metadata, Subscriber};
-use tracing_subscriber::layer::{Context, Filter};
+use tracing_subscriber::layer::Context;
 use tracing_subscriber::registry::{LookupSpan, SpanRef};
 use tracing_subscriber::Layer;
 

runtime/console/src/server.rs

@@ -4,11 +4,9 @@ use async_compat::CompatExt;
 use console_api::instrument;
 use console_api::instrument::instrument_server::{Instrument, InstrumentServer};
 use console_api::tasks;
-use futures_util::TryStreamExt;
 use std::error::Error;
-use std::future::Future;
 use std::io::IoSlice;
-use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr};
+use std::net::{IpAddr, Ipv4Addr, SocketAddr};
 use std::pin::Pin;
 use std::task::{Context, Poll};
 use tokio::io::AsyncRead as TokioAsyncRead;
@@ -95,7 +93,7 @@ impl Server {
     }
 
     pub async fn serve(
-        mut self, /*, incoming: I */
+        self, /*, incoming: I */
     ) -> Result<(), Box<dyn Error + Send + Sync + 'static>> {
         let svc = InstrumentServer::new(self);