equal
deleted
inserted
replaced
100 ) -> Result<HwProtocolMessage> { |
100 ) -> Result<HwProtocolMessage> { |
101 use ProtocolError::*; |
101 use ProtocolError::*; |
102 |
102 |
103 loop { |
103 loop { |
104 if !self.buffer.has_remaining() { |
104 if !self.buffer.has_remaining() { |
|
105 //todo!("ensure the buffer doesn't grow indefinitely") |
105 match timeout(self.read_timeout, stream.read_buf(&mut self.buffer)).await { |
106 match timeout(self.read_timeout, stream.read_buf(&mut self.buffer)).await { |
106 Err(_) => return Err(Timeout), |
107 Err(_) => return Err(Timeout), |
107 Ok(Err(e)) => return Err(Network(Box::new(e))), |
108 Ok(Err(e)) => return Err(Network(Box::new(e))), |
108 Ok(Ok(0)) => return Err(Eof), |
109 Ok(Ok(0)) => return Err(Eof), |
109 Ok(Ok(_)) => (), |
110 Ok(Ok(_)) => (), |