From 4821d51167066b4d62f39fffc5d59e1014cb7279 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Sat, 27 Jan 2018 11:15:03 -0800
Subject: [PATCH] fix actix compatibility
---
src/server/srv.rs | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/server/srv.rs b/src/server/srv.rs
index 47309e70..0e8f6485 100644
--- a/src/server/srv.rs
+++ b/src/server/srv.rs
@@ -386,7 +386,8 @@ impl<H: HttpHandler, U, V> HttpServer<TlsStream<TcpStream>, net::SocketAddr, H,
// start http server actor
let signals = self.subscribe_to_signals();
let addr: SyncAddress<_> = Actor::start(self);
- signals.map(|signals| signals.send(signal::Subscribe(addr.subscriber())));
+ signals.map(|signals| signals.send(
+ signal::Subscribe(addr.clone().into_subscriber())));
Ok(addr)
}
}
@@ -431,7 +432,8 @@ impl<H: HttpHandler, U, V> HttpServer<SslStream<TcpStream>, net::SocketAddr, H,
// start http server actor
let signals = self.subscribe_to_signals();
let addr: SyncAddress<_> = Actor::start(self);
- signals.map(|signals| signals.send(signal::Subscribe(addr.subscriber())));
+ signals.map(|signals| signals.send(
+ signal::Subscribe(addr.clone().into_subscriber())));
Ok(addr)
}
}