Function create_file_sink

parser/src/serde.rs:30–41

(path: T)

}

async fn create_file_sink<T>(path: T) -> Result<sea_streamer_file::FileSink>
where
    T: Into<String>,
{
    let file_id = sea_streamer_file::FileId::new(path);
    let async_file = sea_streamer_file::AsyncFile::new_ow(file_id)
        .await
        .context("Fail to create async file")?;
    let res = sea_streamer_file::FileSink::new(async_file, 1_000_000_000)
        .context("Fail to create file sink")?;
    Ok(res)
}

pub async fn from_bson_file<T>(path: &str) -> Result<T>
where