Close Messenger connection on reset
This commit is contained in:
parent
cf95b52f7e
commit
e1ebfab247
|
@ -109,6 +109,10 @@ impl<T: Read + Write, I: DeserializeOwned, O: Serialize> Messenger<T, I, O> {
|
||||||
self.closed = true;
|
self.closed = true;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
Err(ref err) if err.kind() == std::io::ErrorKind::ConnectionReset => {
|
||||||
|
self.closed = true;
|
||||||
|
break;
|
||||||
|
}
|
||||||
Ok(n) => {
|
Ok(n) => {
|
||||||
self.received_buf.write(&buf[..n])?;
|
self.received_buf.write(&buf[..n])?;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue