Function to_json_file

parser/src/serde.rs:18–28

(path: &str, json: &S)

}

pub async fn to_json_file<S>(path: &str, json: &S) -> Result<()>
where
    S: serde::Serialize,
{
    let mut file_sink = create_file_sink(path)
        .await
        .context("Fail to create file sink")?;
    serde_json::to_writer_pretty(file_sink.as_writer(), json).context("Fail to write JSON")?;
    file_sink.flush(1).await.context("Fail to flush")?;
    Ok(())
}

async fn create_file_sink<T>(path: T) -> Result<sea_streamer_file::FileSink>
where