pub fn load_paths_futures<'a, P, I>(
    paths: I,
    config: RecordIndexerConfig,
) -> impl Stream<Item = impl Future<Output = Result<impl Stream<Item = Result<RecordIndex>>>>>
where
    I: IntoIterator<Item = P>,
    P: Into<Cow<'a, std::path::Path>>,
{
    stream::iter(paths)
        .map(|path| path.into().into_owned())
        .map(move |path| load_file_async(path, config.clone()))
}
/// Generate futures that load record indexes from file paths.
Generate futures that load record indexes from file paths.
Generate futures that load record indexes from file paths .
pub fn load_paths_futures<'a, P, I>(
    paths: I,
    config: RecordIndexerConfig,
) -> impl Stream<Item = impl Future<Output = Result<impl Stream<Item = Result<RecordIndex>>>>>
where
    I: IntoIterator<Item = P>,
    P: Into<Cow<'a, std::path::Path>>,
{
    stream::iter(paths)
        .map(|path| path.into().into_owned())
        .map(move |path| load_file_async(path, config.clone()))
}
pub fn load_paths_futures < ' a , P , I > ( paths : I , config : RecordIndexerConfig , ) -> impl Stream < Item = impl Future < Output = Result < impl Stream < Item = Result < RecordIndex > > > > > where I : IntoIterator < Item = P > , P : Into < Cow < ' a , std :: path :: Path > > , { stream :: iter ( paths ) . map ( | path | path . into ( ) . into_owned ( ) ) . map ( move | path | load_file_async ( path , config . clone ( ) ) ) }
Generate futures that load record indexes from file paths.
Generate futures that load record indexes from file paths .
paths
I
config
RecordIndexerConfig
paths
I
config
RecordIndexerConfig