letmeind/src/main.rs

@@ -226,7 +226,7 @@ async fn async_main(opts: Arc<Opts>) -> ah::Result<()> {
                             let conn = Arc::clone(&conn);
                             task::spawn(async move {
                                 let conf = conf.read().await;
-                                let mut proto = Protocol::new(&conn, &conf, &opts.rundir);
+                                let mut proto = Protocol::new(&*conn, &conf, &opts.rundir);
                                 if let Err(e) = proto.run().await {
                                     eprintln!("Client '{}' ERROR: {}", proto.peer_addr().ip(), e);
                                 }

letmeind/src/protocol.rs

@@ -31,7 +31,7 @@ enum AuthState {
 }
 
 /// Implementation of the wire protocol message sequence.
-pub struct Protocol<'a, C: ConnectionOps> {
+pub struct Protocol<'a, C> {
     conn: &'a C,
     conf: &'a Config,
     rundir: &'a Path,

letmeind/src/server.rs

@@ -46,7 +46,7 @@ impl Connection {
     }
 }
 
-impl ConnectionOps for Arc<Connection> {
+impl ConnectionOps for Connection {
     fn peer_addr(&self) -> SocketAddr {
         self.peer_addr
     }