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

use std::io;

use serde_json::Error as Jrror;

use tokio_stream::{Stream, StreamExt};

pub fn from_strings<S, T, C>(strings: S, conv: C) -> impl Stream<Item = Result<T, Jrror>>
where
    S: Stream<Item = Result<String, io::Error>>,
    C: Fn(Result<String, io::Error>) -> Result<T, Jrror>,
{
    strings.map(conv)
}

pub fn from_slices<S, T, C>(slices: S, conv: C) -> impl Stream<Item = Result<T, Jrror>>
where
    S: Stream<Item = Result<Vec<u8>, io::Error>>,
    C: Fn(Result<Vec<u8>, io::Error>) -> Result<T, Jrror>,
{
    slices.map(conv)
}