mirror of
https://github.com/fafhrd91/actix-net
synced 2025-06-27 00:27:43 +02:00
fix error handling
This commit is contained in:
@ -371,7 +371,9 @@ where
|
||||
}
|
||||
}
|
||||
TransportState::Error(err) => {
|
||||
if self.poll_response() || !self.framed.is_write_buf_empty() {
|
||||
if self.framed.is_write_buf_empty()
|
||||
|| (self.poll_response() || self.framed.is_write_buf_empty())
|
||||
{
|
||||
Err(err)
|
||||
} else {
|
||||
self.state = TransportState::Error(err);
|
||||
|
Reference in New Issue
Block a user