changeset 12130 | 6273f89ab13d |
parent 12129 | 07972a8c2433 |
child 12131 | a4d22f197bd2 |
12129:07972a8c2433 | 12130:6273f89ab13d |
---|---|
1 use netbuf; |
|
2 use std::io::Read; |
|
3 use std::io::Result; |
|
4 |
|
5 |
|
6 pub struct FrameDecoder { |
|
7 buf: netbuf::Buf, |
|
8 } |
|
9 |
|
10 impl FrameDecoder { |
|
11 pub fn new() -> FrameDecoder { |
|
12 FrameDecoder { |
|
13 buf: netbuf::Buf::new() |
|
14 } |
|
15 } |
|
16 |
|
17 pub fn read_from<R: Read>(&mut self, stream: &mut R) -> Result<usize> { |
|
18 self.buf.read_from(stream) |
|
19 } |
|
20 |
|
21 pub fn extract_messages(&mut self) -> &[u8] { |
|
22 &self.buf[..] |
|
23 } |
|
24 } |