rama-http 0.3.0-rc1

rama http layers, services and other utilities
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

use rama_core::error::BoxError;
use rama_core::futures::Stream;
use rama_core::stream::json::JsonWriteStream;
use serde::Serialize;

use crate::headers::ContentType;
use crate::service::web::response::Headers;
use crate::{Body, Response};

use super::IntoResponse;

impl<S, T, E> IntoResponse for JsonWriteStream<S>
where
    S: Stream<Item = Result<T, E>> + Send + 'static,
    T: Serialize,
    E: Into<BoxError>,
{
    #[inline(always)]
    fn into_response(self) -> Response {
        (
            Headers::single(ContentType::ndjson()),
            Body::from_stream(self),
        )
            .into_response()
    }
}