monoio-netreq 0.1.2

monoio-netreq is a user-friendly HTTP client library designed for use with the Monoio runtime
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

use std::marker::PhantomData;
use std::pin::Pin;
use std::task::{Context, Poll};

use bytes::Bytes;
use hyper::body::{Body as HttpBody, Frame};
use hyper::Error;

use crate::request::RequestBody;

#[derive(Debug, Clone)]
pub struct HyperBody {
    _marker: PhantomData<*const ()>,
    data: Option<Bytes>,
}

impl From<Bytes> for HyperBody {
    fn from(a: Bytes) -> Self {
        HyperBody {
            _marker: PhantomData,
            data: Some(a.into()),
        }
    }
}

impl HttpBody for HyperBody {
    type Data = Bytes;
    type Error = Error;

    fn poll_frame(
        self: Pin<&mut Self>,
        _: &mut Context<'_>,
    ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> {
        Poll::Ready(self.get_mut().data.take().map(|d| Ok(Frame::data(d))))
    }
}

impl RequestBody for HyperBody {
    type Body = HyperBody;

    fn create_body(bytes: Option<Bytes>) -> Self::Body {
        bytes.unwrap_or_default().into()
    }
}