This commit is contained in:
Nikolay Kim 2025-03-28 19:43:17 +01:00
parent dfeefd0afd
commit 3455bec5bd

View file

@ -178,7 +178,7 @@ impl<T> Handler for StreamOpsHandler<T> {
item.fd, item.fd,
item.io.is_some() item.io.is_some()
); );
if item.io.is_some() { if item.io.take().is_some() {
close(id, &mut item, &self.inner.api, false); close(id, &mut item, &self.inner.api, false);
} }
} }
@ -371,7 +371,7 @@ impl<T> Drop for StreamCtl<T> {
item.fd, item.fd,
item.io.is_some() item.io.is_some()
); );
if item.io.is_some() { if item.io.take().is_some() {
close(self.id, &mut item, &self.inner.api, true); close(self.id, &mut item, &self.inner.api, true);
} }
} }