nyquest 0.4.0

truly platform-native HTTP client 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

use std::io;

use nyquest_interface::blocking::AnyBlockingResponse;

/// An [`std::io::Read`] stream backed by a blocking response.
pub struct ReadStream {
    inner: Box<dyn AnyBlockingResponse>,
}

impl ReadStream {
    pub(crate) fn new(inner: Box<dyn AnyBlockingResponse>) -> Self {
        Self { inner }
    }
}

impl io::Read for ReadStream {
    fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
        self.inner.read(buf)
    }
}

mod trait_assert {
    trait _AssertMarker: Send + Sync {}
    impl _AssertMarker for super::ReadStream {}
}