vortex-io 0.69.0

Core async and blocking IO traits and implementations, used by IPC and file format
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

// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

use std::sync::Arc;

use async_trait::async_trait;
use futures::StreamExt;
use futures::stream::BoxStream;
use vortex_error::VortexResult;

use crate::VortexReadAt;
use crate::compat::Compat;
use crate::filesystem::FileListing;
use crate::filesystem::FileSystem;

/// Compatibility adapter for `FileSystem` implementations that are based on Tokio.
#[deny(clippy::missing_trait_methods)]
#[async_trait]
impl<F: FileSystem> FileSystem for Compat<F> {
    fn list(&self, prefix: &str) -> BoxStream<'_, VortexResult<FileListing>> {
        Compat::new(self.inner().list(prefix)).boxed()
    }

    async fn open_read(&self, path: &str) -> VortexResult<Arc<dyn VortexReadAt>> {
        let read_at = Compat::new(self.inner().open_read(path)).await?;
        Ok(Arc::new(Compat::new(read_at)))
    }
}