From 348491b18c9a2f0920595a27732537f248e924e2 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Sat, 23 Jun 2018 17:59:45 +0600
Subject: [PATCH] fix alpn connector

---
 src/client/connector.rs | 11 ++++++-----
 src/pipeline.rs         |  2 +-
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/src/client/connector.rs b/src/client/connector.rs
index f8c7ba7c7..6c32d898e 100644
--- a/src/client/connector.rs
+++ b/src/client/connector.rs
@@ -837,9 +837,9 @@ impl fut::ActorFuture for Maintenance {
         act.collect_waiters();
 
         // check waiters
-        let mut waiters = act.waiters.take().unwrap();
+        let mut act_waiters = act.waiters.take().unwrap();
 
-        for (key, waiters) in &mut waiters {
+        for (key, ref mut waiters) in &mut act_waiters {
             while let Some(waiter) = waiters.pop_front() {
                 if waiter.tx.is_canceled() {
                     continue;
@@ -858,10 +858,11 @@ impl fut::ActorFuture for Maintenance {
                         break;
                     }
                     Acquire::Available => {
+                        let key = key.clone();
                         let conn = AcquiredConn(key.clone(), Some(act.acq_tx.clone()));
 
                         fut::WrapFuture::<ClientConnector>::actfuture(
-                            Resolver::from_registry().send(
+                            act.resolver.as_ref().unwrap().send(
                                 ResolveConnect::host_and_port(&conn.0.host, conn.0.port)
                                     .timeout(waiter.conn_timeout),
                             ),
@@ -898,7 +899,7 @@ impl fut::ActorFuture for Maintenance {
                                                         }
                                                         Ok(())
                                                     })
-                                                    .actfuture(),
+                                                    .into_actor(act),
                                             )
                                         } else {
                                             let _ = waiter.tx.send(Ok(Connection::new(
@@ -986,7 +987,7 @@ impl fut::ActorFuture for Maintenance {
             }
         }
 
-        act.waiters = Some(waiters);
+        act.waiters = Some(act_waiters);
         Ok(Async::NotReady)
     }
 }
diff --git a/src/pipeline.rs b/src/pipeline.rs
index 458436820..87400e297 100644
--- a/src/pipeline.rs
+++ b/src/pipeline.rs
@@ -841,7 +841,7 @@ mod tests {
                     Pipeline(info, PipelineState::Completed(state), Rc::new(Vec::new()));
                 assert!(!pp.is_done());
 
-                let Pipeline(mut info, st, mws) = pp;
+                let Pipeline(mut info, st, _) = pp;
                 let mut st = st.completed().unwrap();
                 drop(addr);