manas_http 0.1.1

This crate provides extended functionality for handling http semantics, that integrates into [`hyper`](https://docs.rs/hyper/latest/hyper/index.html) ecosystem.
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

//! I define type to represent streaming quads data.
//!

use async_convert::async_trait;
use ecow::EcoVec;
use futures::{stream::BoxStream, TryStreamExt};
use hyper::body::SizeHint;
use rdf_utils::model::{dataset::CompatDataset, quad::ArcQuad};

use super::quads_inmem::{EcoQuadsInmem, QuadsInmem};

/// Type alias for a boxed fallible quads stream.
pub type BoxQuadsStream = BoxStream<'static, Result<ArcQuad, anyhow::Error>>;

/// Quads stream data.
pub struct QuadsStream {
    /// Data stream.
    pub stream: BoxQuadsStream,

    /// Size hint.
    pub size_hint: SizeHint,
}

impl std::fmt::Debug for QuadsStream {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("QuadsStream")
            .field("size_hint", &self.size_hint)
            .finish()
    }
}

impl From<EcoQuadsInmem> for QuadsStream {
    fn from(value: EcoQuadsInmem) -> Self {
        Self {
            size_hint: SizeHint::with_exact(value.len() as u64),
            stream: Box::pin(futures::stream::iter(
                value.into_inner().0.into_iter().map(Ok),
            )),
        }
    }
}

#[async_trait]
impl async_convert::TryFrom<QuadsStream> for EcoQuadsInmem {
    type Error = anyhow::Error;

    async fn try_from(data: QuadsStream) -> Result<Self, Self::Error> {
        Ok(QuadsInmem::new(CompatDataset(
            data.stream.try_collect::<EcoVec<_>>().await?,
        )))
    }
}