equal
deleted
inserted
replaced
44 } |
44 } |
45 |
45 |
46 pub fn extract_messages(&mut self) -> Vec<messages::HwProtocolMessage> { |
46 pub fn extract_messages(&mut self) -> Vec<messages::HwProtocolMessage> { |
47 let mut messages = vec![]; |
47 let mut messages = vec![]; |
48 if !self.is_recovering { |
48 if !self.is_recovering { |
49 loop { |
49 while !self.buf.is_empty() { |
50 match parser::message(&self.buf[..]) { |
50 match parser::message(&self.buf[..]) { |
51 Ok((tail, message)) => { |
51 Ok((tail, message)) => { |
52 messages.push(message); |
52 messages.push(message); |
53 self.buf.consume(self.buf.len() - tail.len()); |
53 self.buf.consume(self.buf.len() - tail.len()); |
54 } |
54 } |