mirror of
https://github.com/actix/actix-extras.git
synced 2024-11-30 18:34:36 +01:00
actix compatibility
This commit is contained in:
parent
2faf3a5eb6
commit
bc6300be34
@ -387,7 +387,7 @@ impl<H: HttpHandler, U, V> HttpServer<TlsStream<TcpStream>, net::SocketAddr, H,
|
||||
let signals = self.subscribe_to_signals();
|
||||
let addr: SyncAddress<_> = Actor::start(self);
|
||||
signals.map(|signals| signals.send(
|
||||
signal::Subscribe(addr.clone().into_subscriber())));
|
||||
signal::Subscribe(addr.clone().into())));
|
||||
Ok(addr)
|
||||
}
|
||||
}
|
||||
@ -433,7 +433,7 @@ impl<H: HttpHandler, U, V> HttpServer<SslStream<TcpStream>, net::SocketAddr, H,
|
||||
let signals = self.subscribe_to_signals();
|
||||
let addr: SyncAddress<_> = Actor::start(self);
|
||||
signals.map(|signals| signals.send(
|
||||
signal::Subscribe(addr.clone().into_subscriber())));
|
||||
signal::Subscribe(addr.clone().into())));
|
||||
Ok(addr)
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user