This commit is contained in:
Nikolay Kim 2023-03-11 09:52:29 +01:00
parent a98f63b1bf
commit 3db65156ee
2 changed files with 2 additions and 2 deletions

View file

@ -112,7 +112,7 @@ impl Future for Signals {
{ {
for (sig, stream, kind) in self.signals.iter_mut() { for (sig, stream, kind) in self.signals.iter_mut() {
loop { loop {
if let Poll::Ready(res) = Pin::new(&mut *stream).poll_recv(cx) { if Pin::new(&mut *stream).poll_recv(cx).is_ready() {
let handlers = SHANDLERS.with(|h| mem::take(&mut *h.borrow_mut())); let handlers = SHANDLERS.with(|h| mem::take(&mut *h.borrow_mut()));
for sender in handlers { for sender in handlers {
let _ = sender.send(*sig); let _ = sender.send(*sig);

View file

@ -1,6 +1,6 @@
[package] [package]
name = "ntex" name = "ntex"
version = "0.6.3" version = "0.6.4"
authors = ["ntex contributors <team@ntex.rs>"] authors = ["ntex contributors <team@ntex.rs>"]
description = "Framework for composable network services" description = "Framework for composable network services"
readme = "README.md" readme = "README.md"