diff --git a/ntex-net/src/rt_polling/driver.rs b/ntex-net/src/rt_polling/driver.rs index f03af7de..981bdcb3 100644 --- a/ntex-net/src/rt_polling/driver.rs +++ b/ntex-net/src/rt_polling/driver.rs @@ -178,7 +178,7 @@ impl Handler for StreamOpsHandler { item.fd, item.io.is_some() ); - if item.io.is_some() { + if item.io.take().is_some() { close(id, &mut item, &self.inner.api, false); } } @@ -371,7 +371,7 @@ impl Drop for StreamCtl { item.fd, item.io.is_some() ); - if item.io.is_some() { + if item.io.take().is_some() { close(self.id, &mut item, &self.inner.api, true); } }