datapipe 0.1.4

Stream data from here to there
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

/// Writer for file output
use crate::datapipe_types::OutputWriter;
use std::io::Error;
use std::path::Path;
use tokio::io::AsyncWriteExt;

#[derive(Debug)]
pub struct FileWriter {
    file: tokio::fs::File,
}

impl FileWriter {
    pub async fn new(pathref: &Path) -> Result<Self, Error> {
        Ok(Self {
            file: tokio::fs::OpenOptions::new()
                .create(true)
                .write(true)
                .append(true)
                .open(pathref)
                .await?,
        })
    }
}

impl OutputWriter for FileWriter {
    async fn write(&mut self, bytes: &[u8]) -> Result<(), Error> {
        match self.file.write(bytes).await {
            Ok(_size) => Ok(()),
            Err(error) => Err(error),
        }
    }
}