fix some errors

Watfaq · Dec 6, 2023 · 452af1f · 452af1f
1 parent f0fe9a6
commit 452af1f
Show file tree

Hide file tree

Showing 5 changed files with 256 additions and 256 deletions.
diff --git a/clash_lib/src/app/dispatcher/dispatcher.rs b/clash_lib/src/app/dispatcher/dispatcher.rs
@@ -11,7 +11,7 @@ use crate::proxy::AnyInboundDatagram;
 use crate::session::Session;
 use futures::SinkExt;
 use futures::StreamExt;
-use tokio::io::AsyncReadExt;
+
 use std::collections::HashMap;
 use std::fmt::{Debug, Formatter};
 use std::net::SocketAddr;
@@ -78,7 +78,7 @@ impl Dispatcher {
     #[instrument(skip(lhs))]
     pub async fn dispatch_stream<S>(&self, sess: Session, mut lhs: S)
     where
-        S: AsyncRead + AsyncWrite + Unpin + Send,
+        S: AsyncRead + AsyncWrite + Unpin + Send +'static,
     {
         let sess = if self.resolver.fake_ip_enabled() {
             match sess.destination {
@@ -134,7 +134,7 @@ impl Dispatcher {
         {
             Ok(rhs) => {
                 debug!("remote connection established {}", sess);
-                let mut rhs =
+                let rhs =
                     TrackedStream::new(rhs, self.manager.clone(), sess.clone(), rule).await;
                 match copy_buf_bidirectional_with_timeout(
                     lhs,