hreq 0.8.0

hreq is a user first async http client
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

use crate::Error;
use bytes::Bytes;
use futures_util::future::poll_fn;
use h2;
use hreq_h1 as h1;

/// Generalisation over sending body data.
pub(crate) enum BodySender {
    H1(h1::SendStream),
    H2(h2::SendStream<Bytes>),
}

impl BodySender {
    pub async fn send_data(&mut self, mut buf: &[u8]) -> Result<(), Error> {
        if buf.is_empty() {
            return Ok(());
        }

        match self {
            BodySender::H1(s) => Ok(s.send_data(buf, false).await?),
            BodySender::H2(s) => {
                loop {
                    if buf.len() == 0 {
                        break;
                    }

                    let actual_capacity = loop {
                        s.reserve_capacity(buf.len());

                        let capacity = s.capacity();

                        if capacity > 0 {
                            break capacity;
                        }

                        // wait for capacity to increase
                        let capacity = poll_fn(|cx| s.poll_capacity(cx))
                            .await
                            .ok_or_else(|| Error::Proto("Stream gone before capacity".into()))??;

                        if capacity > 0 {
                            break capacity;
                        }
                    };

                    let data = (&buf[..actual_capacity]).to_vec().into();

                    s.send_data(data, false)?;

                    buf = &buf[actual_capacity..];
                }

                Ok(())
            }
        }
    }

    pub async fn send_end(&mut self) -> Result<(), Error> {
        match self {
            BodySender::H1(s) => Ok(s.send_data(&[], true).await?),
            BodySender::H2(s) => Ok(s.send_data(Bytes::new(), true)?),
        }
    }
}