http1 0.0.2

http1 codec types
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use bytes::{Bytes, BytesMut};

pub struct LengthDecoder {
    remaining: u64,
}

pub struct Error;

impl LengthDecoder {
    pub fn new(length: u64) -> Self {
        LengthDecoder { remaining: length }
    }
}

impl super::Decoder for LengthDecoder {
    type Item = Bytes; // can it just be BytesMut?
    type Error = Error;

    fn decode(&mut self, bytes: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> {
        debug_assert!(!bytes.is_empty(), "decode should always be called with bytes");
        if self.remaining == 0 {
            Ok(Some(Bytes::new()))
        } else {
            let to_read = bytes.len().min(self.remaining as usize);
            self.remaining -= to_read as u64;
            Ok(Some(bytes.split_to(to_read).freeze()))
        }
    }
}