equal
deleted
inserted
replaced
1 use netbuf; |
1 use netbuf; |
2 use nom::{Err, IResult}; |
2 use nom::{Err, ErrorKind, IResult}; |
3 use std::io::{Read, Result}; |
3 use std::io::{Read, Result}; |
4 |
4 |
5 pub mod messages; |
5 pub mod messages; |
6 mod parser; |
6 mod parser; |
7 #[cfg(test)] |
7 #[cfg(test)] |
29 match parse_result { |
29 match parse_result { |
30 Ok((tail, msgs)) => { |
30 Ok((tail, msgs)) => { |
31 self.consumed = self.buf.len() - self.consumed - tail.len(); |
31 self.consumed = self.buf.len() - self.consumed - tail.len(); |
32 msgs |
32 msgs |
33 } |
33 } |
34 Err(Err::Incomplete(_)) => unreachable!(), |
34 _ => unreachable!(), |
35 Err(Err::Error(_)) | Err(Err::Failure(_)) => unreachable!(), |
|
36 } |
35 } |
37 } |
36 } |
38 |
37 |
39 pub fn sweep(&mut self) { |
38 pub fn sweep(&mut self) { |
40 self.buf.consume(self.consumed); |
39 self.buf.consume(self.consumed); |