Update registration after every write (#4102)
This commit is contained in:
parent
e86b955815
commit
d67ceec50c
@ -158,8 +158,8 @@ impl<Socket: GenericSocket> GenericConnection<Socket> {
|
|||||||
}
|
}
|
||||||
if self.send_queue.is_empty() {
|
if self.send_queue.is_empty() {
|
||||||
self.interest.remove(Ready::writable());
|
self.interest.remove(Ready::writable());
|
||||||
io.update_registration(self.token)?;
|
|
||||||
}
|
}
|
||||||
|
io.update_registration(self.token)?;
|
||||||
Ok(r)
|
Ok(r)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user