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 } }