pub async fn list<'a>(
        &'a self,
        prefix: Option<&'a str>,
    ) -> Result<impl Stream<Item = Result<Vec<String>>> + 'a> {
        use ObjectStoreIntegration::*;
        Ok(match &self.0 {
            AmazonS3(s3) => s3.list(prefix).await?.boxed(),
            GoogleCloudStorage(gcs) => gcs.list(prefix).await?.boxed(),
            InMemory(in_mem) => in_mem.list(prefix).await?.boxed(),
            File(file) => file.list(prefix).await?.boxed(),
        }
        .err_into())
    }
/// List all the objects with the given prefix.
List all the objects with the given prefix.
List all the objects with the given prefix .
pub async fn list<'a>(
        &'a self,
        prefix: Option<&'a str>,
    ) -> Result<impl Stream<Item = Result<Vec<String>>> + 'a> {
        use ObjectStoreIntegration::*;
        Ok(match &self.0 {
            AmazonS3(s3) => s3.list(prefix).await?.boxed(),
            GoogleCloudStorage(gcs) => gcs.list(prefix).await?.boxed(),
            InMemory(in_mem) => in_mem.list(prefix).await?.boxed(),
            File(file) => file.list(prefix).await?.boxed(),
        }
        .err_into())
    }
pub async fn list < ' a > ( & ' a self , prefix : Option < & ' a str > , ) -> Result < impl Stream < Item = Result < Vec < String > > > + ' a > { use ObjectStoreIntegration :: * ; Ok ( match & self . 0 { AmazonS3 ( s3 ) => s3 . list ( prefix ) . await ? . boxed ( ) , GoogleCloudStorage ( gcs ) => gcs . list ( prefix ) . await ? . boxed ( ) , InMemory ( in_mem ) => in_mem . list ( prefix ) . await ? . boxed ( ) , File ( file ) => file . list ( prefix ) . await ? . boxed ( ) , } . err_into ( ) ) }
List all the objects with the given prefix.
List all the objects with the given prefix .
&'a self
prefix
Option<&'a str>