From a544034c06cde998f621044199531492f92c4927 Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Mon, 12 Feb 2018 22:09:31 -0800 Subject: [PATCH] use Recipient --- src/server/srv.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/server/srv.rs b/src/server/srv.rs index 69b46bc7f..2df542883 100644 --- a/src/server/srv.rs +++ b/src/server/srv.rs @@ -290,7 +290,7 @@ impl HttpServer let signals = self.subscribe_to_signals(); let addr: Addr = Actor::start(self); signals.map(|signals| signals.send( - signal::Subscribe(addr.clone().subscriber()))); + signal::Subscribe(addr.clone().recipient()))); addr } } @@ -352,7 +352,7 @@ impl HttpServer let signals = self.subscribe_to_signals(); let addr: Addr = Actor::start(self); signals.map(|signals| signals.send( - signal::Subscribe(addr.clone().subscriber()))); + signal::Subscribe(addr.clone().recipient()))); Ok(addr) } } @@ -396,7 +396,7 @@ impl HttpServer let signals = self.subscribe_to_signals(); let addr: Addr = Actor::start(self); signals.map(|signals| signals.send( - signal::Subscribe(addr.clone().subscriber()))); + signal::Subscribe(addr.clone().recipient()))); Ok(addr) } } @@ -443,7 +443,7 @@ impl HttpServer self }); signals.map(|signals| signals.send( - signal::Subscribe(addr.clone().subscriber()))); + signal::Subscribe(addr.clone().recipient()))); addr } }