mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 04:47:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Nikolay Kim 2025-03-28 19:31:09 +01:00
parent f04c48e28d
commit a544163dd9
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
ntex-net/src/rt_polling/driver.rs
View file

@ -115,8 +115,8 @@ impl<T> Handler for StreamOpsHandler<T> {
// handle HUP
if ev.is_interrupt() {
item.context.stopped(None);
if item.io.take().is_some() {
item.context.stopped(None);
close(id as u32, item, &self.inner.api, true);
}
return;
@ -200,8 +200,8 @@ impl<T> Handler for StreamOpsHandler<T> {
err
);
item.flags.insert(Flags::ERROR);
item.context.stopped(Some(err));
if item.io.take().is_some() {
item.context.stopped(Some(err));
close(id as u32, item, &self.inner.api, true);
}
}