vortex-io 0.70.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

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

use crate::IoBuf;
use crate::VortexWrite;
use crate::compat::Compat;

/// Compatibility adapter for `VortexWrite` implementations that are based on Tokio.
#[deny(clippy::missing_trait_methods)]
impl<W: VortexWrite> VortexWrite for Compat<W> {
    fn write_all<B: IoBuf>(&mut self, buffer: B) -> impl Future<Output = std::io::Result<B>> {
        Compat::new(self.inner_mut().write_all(buffer))
    }

    fn flush(&mut self) -> impl Future<Output = std::io::Result<()>> {
        Compat::new(self.inner_mut().flush())
    }

    fn shutdown(&mut self) -> impl Future<Output = std::io::Result<()>> {
        Compat::new(self.inner_mut().shutdown())
    }
}