reqrio 0.2.0

A lightweight, high concurrency HTTP request library
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use crate::error::HlsResult;
use crate::form_data::{HttpFile, HttpFileReader};
use crate::packet::H2BodyReader;
use crate::reader::{ReadExt, Reader};
use reqtls::WriteExt;
use std::io::{Cursor, Read};

pub(crate) enum BodyType {
    Bytes(Vec<u8>),
    Files(HttpFile),
}

impl BodyType {
    pub fn new_byte(bytes: Vec<u8>) -> Self {
        BodyType::Bytes(bytes)
    }

    pub fn as_reader(&self) -> HlsResult<H1BodyReader<'_>> {
        match self {
            BodyType::Bytes(bs) => Ok(H1BodyReader::Bytes(Cursor::new(bs))),
            BodyType::Files(hfs) => Ok(H1BodyReader::Files(hfs.as_reader()?))
        }
    }
}


pub(crate) enum H1BodyReader<'a> {
    Bytes(Cursor<&'a [u8]>),
    Files(HttpFileReader<'a>),
}

impl<'a> ReadExt for H1BodyReader<'a> {
    fn wrote(&self) -> bool {
        match self {
            H1BodyReader::Bytes(bs) => bs.position() as usize == bs.get_ref().len(),
            H1BodyReader::Files(fs) => fs.wrote(),
        }
    }
    fn len(&self) -> usize {
        match self {
            H1BodyReader::Bytes(bs) => bs.get_ref().len(),
            H1BodyReader::Files(hfs) => hfs.len(),
        }
    }

    fn read(&mut self, buf: &mut Reader) -> HlsResult<usize> {
        match self {
            H1BodyReader::Bytes(bs) => {
                let len = bs.read(buf.unfilled())?;
                buf.add_len(len);
                Ok(len)
            }
            H1BodyReader::Files(hfs) => hfs.read(buf),
        }
    }
}

pub(crate) enum BodyReader<'a> {
    HTTP1(H1BodyReader<'a>),
    HTTP2(H2BodyReader<'a>),
}

impl<'a> ReadExt for BodyReader<'a> {
    fn wrote(&self) -> bool {
        match self {
            BodyReader::HTTP1(h1) => h1.wrote(),
            BodyReader::HTTP2(h2) => h2.wrote(),
        }
    }

    fn len(&self) -> usize {
        match self {
            BodyReader::HTTP1(h1) => h1.len(),
            BodyReader::HTTP2(h2) => h2.len(),
        }
    }

    fn read(&mut self, buf: &mut Reader) -> HlsResult<usize> {
        match self {
            BodyReader::HTTP1(h1) => h1.read(buf),
            BodyReader::HTTP2(h2) => h2.read(buf)
        }
    }
}