do not unwrap stream write, TcpStream::shutdown results (#492)
This commit is contained in:
@@ -107,7 +107,7 @@ impl Drop for StreamInstance {
|
|||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
match self {
|
match self {
|
||||||
StreamInstance::TcpStream(_, ref mut tcp_stream) => {
|
StreamInstance::TcpStream(_, ref mut tcp_stream) => {
|
||||||
tcp_stream.shutdown(Shutdown::Both).unwrap();
|
discard_result!(tcp_stream.shutdown(Shutdown::Both));
|
||||||
}
|
}
|
||||||
_ => {
|
_ => {
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2065,13 +2065,13 @@ impl MachineState {
|
|||||||
match Number::try_from((addr, &self.heap)) {
|
match Number::try_from((addr, &self.heap)) {
|
||||||
Ok(Number::Integer(n)) => {
|
Ok(Number::Integer(n)) => {
|
||||||
if let Some(nb) = n.to_u8() {
|
if let Some(nb) = n.to_u8() {
|
||||||
stream.write(&mut [nb]).unwrap();
|
discard_result!(stream.write(&mut [nb]));
|
||||||
return return_from_clause!(self.last_call, self);
|
return return_from_clause!(self.last_call, self);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Ok(Number::Fixnum(n)) => {
|
Ok(Number::Fixnum(n)) => {
|
||||||
if let Ok(nb) = u8::try_from(n) {
|
if let Ok(nb) = u8::try_from(n) {
|
||||||
stream.write(&mut [nb]).unwrap();
|
discard_result!(stream.write(&mut [nb]));
|
||||||
return return_from_clause!(self.last_call, self);
|
return return_from_clause!(self.last_call, self);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user