fs2db 7.3.0

migration helper
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
33
34
35
36
37
38
39

use std::io;
use std::path::Path;

use tokio::fs::File;
use tokio::io::{AsyncBufReadExt, BufReader};
use tokio_stream::wrappers::{LinesStream, SplitStream};
use tokio_stream::Stream;

async fn path2file<P>(p: P) -> Result<File, io::Error>
where
    P: AsRef<Path>,
{
    File::open(p).await
}

pub async fn path2strings<P>(
    p: P,
) -> Result<impl Stream<Item = Result<String, io::Error>>, io::Error>
where
    P: AsRef<Path>,
{
    let f: File = path2file(p).await?;
    let br = BufReader::new(f);
    let lines = br.lines();
    let ls = LinesStream::new(lines);
    Ok(ls)
}

pub async fn path2slices<P>(
    p: P,
) -> Result<impl Stream<Item = Result<Vec<u8>, io::Error>>, io::Error>
where
    P: AsRef<Path>,
{
    let f: File = path2file(p).await?;
    let br = BufReader::new(f);
    let splited = br.split(b'\n');
    Ok(SplitStream::new(splited))
}