equal
deleted
inserted
replaced
53 messages.push(message); |
53 messages.push(message); |
54 let length = tail.len(); |
54 let length = tail.len(); |
55 self.buf.consume(self.buf.len() - length); |
55 self.buf.consume(self.buf.len() - length); |
56 } |
56 } |
57 Err(nom::Err::Incomplete(_)) => break, |
57 Err(nom::Err::Incomplete(_)) => break, |
58 Err(nom::Err::Failure(e)) | Err(nom::Err::Error(e)) => { |
58 Err(nom::Err::Failure(e) | nom::Err::Error(e)) => { |
59 debug!("Invalid message: {:?}", e); |
59 debug!("Invalid message: {:?}", e); |
60 if !self.recover() || self.buf.is_empty() { |
60 if !self.recover() || self.buf.is_empty() { |
61 break; |
61 break; |
62 } |
62 } |
63 } |
63 } |