Struct NdjsonResponse 

pub struct NdjsonResponse<S, T> { /* private fields */ }

Builder for creating NDJSON streaming responses.

This wraps a stream of serializable items and converts it to an HTTP response with the appropriate Content-Type: application/x-ndjson header.

Example

use fastapi_core::ndjson::NdjsonResponse;
use fastapi_core::Response;
use asupersync::stream;
use serde::Serialize;

#[derive(Serialize)]
struct Record { id: i64, value: f64 }

async fn export_data() -> Response {
    let records = stream::iter(vec![
        Record { id: 1, value: 1.5 },
        Record { id: 2, value: 2.7 },
        Record { id: 3, value: 3.14 },
    ]);

    NdjsonResponse::new(records).into_response()
}

Headers Set

• Content-Type: application/x-ndjson
• Cache-Control: no-cache (streaming data shouldn’t be cached)
• Transfer-Encoding: chunked (implicit for streaming)

Implementations

impl<S, T> NdjsonResponse<S, T>

where S: Stream<Item = T> + Send + Unpin + 'static, T: Serialize + Send + Unpin + 'static,

pub fn new(stream: S) -> Self

Create a new NDJSON response from a stream of serializable items.

pub fn with_config(stream: S, config: NdjsonConfig) -> Self

Create an NDJSON response with custom configuration.

pub fn into_response(self) -> Response

Convert to an HTTP Response.

Sets the appropriate headers for NDJSON streaming:

• Content-Type: application/x-ndjson
• Cache-Control: no-cache
• X-Accel-Buffering: no (disables nginx buffering)