pub async fn load_prefix_async<'a, P>(
    prefix: P,
    config: RecordIndexerConfig,
) -> Result<impl Stream<Item = Result<RecordIndex>>>
where
    P: Into<Cow<'a, str>>,
{
    let stream = load_prefix_futures(prefix, config)
        .await?
        .then(|fut| fut)
        .try_flatten();
    Ok(stream)
}
/// Load record indexes from files specified by a prefix.
Load record indexes from files specified by a prefix.
Load record indexes from files specified by a prefix .
pub async fn load_prefix_async<'a, P>(
    prefix: P,
    config: RecordIndexerConfig,
) -> Result<impl Stream<Item = Result<RecordIndex>>>
where
    P: Into<Cow<'a, str>>,
{
    let stream = load_prefix_futures(prefix, config)
        .await?
        .then(|fut| fut)
        .try_flatten();
    Ok(stream)
}
pub async fn load_prefix_async < ' a , P > ( prefix : P , config : RecordIndexerConfig , ) -> Result < impl Stream < Item = Result < RecordIndex > > > where P : Into < Cow < ' a , str > > , { let stream = load_prefix_futures ( prefix , config ) . await ? . then ( | fut | fut ) . try_flatten ( ) ; Ok ( stream ) }
Load record indexes from files specified by a prefix.
Load record indexes from files specified by a prefix .
prefix
P
config
RecordIndexerConfig
prefix
P
config
RecordIndexerConfig