Trait VortexWrite 

pub trait VortexWrite: Send {
    // Required methods
    fn write_all<B: IoBuf>(
        &mut self,
        buffer: B,
    ) -> impl Future<Output = Result<B>> + Send;
    fn flush(&mut self) -> impl Future<Output = Result<()>> + Send;
    fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send;
}

The unified write trait for Vortex I/O sinks.

Implementations and their returned futures are Send, mirroring VortexReadAt, so writers can be driven from multi-threaded executors and moved into spawned tasks.

Required Methods

fn write_all<B: IoBuf>( &mut self, buffer: B, ) -> impl Future<Output = Result<B>> + Send

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl VortexWrite for ByteBufferMut

fn write_all<B: IoBuf>( &mut self, buffer: B, ) -> impl Future<Output = Result<B>> + Send

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

impl VortexWrite for File

async fn write_all<B: IoBuf>(&mut self, buffer: B) -> Result<B>

async fn flush(&mut self) -> Result<()>

async fn shutdown(&mut self) -> Result<()>

impl VortexWrite for File

async fn write_all<B: IoBuf>(&mut self, buffer: B) -> Result<B>

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

impl VortexWrite for Vec<u8>

fn write_all<B: IoBuf>( &mut self, buffer: B, ) -> impl Future<Output = Result<B>> + Send

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

impl<T: Send> VortexWrite for Cursor<T>

where Cursor<T>: Write,

fn write_all<B: IoBuf>( &mut self, buffer: B, ) -> impl Future<Output = Result<B>> + Send

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

impl<W: VortexWrite> VortexWrite for &mut W

fn write_all<B: IoBuf>( &mut self, buffer: B, ) -> impl Future<Output = Result<B>> + Send

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

impl<W: VortexWrite> VortexWrite for Cursor<W>

fn write_all<B: IoBuf>( &mut self, buffer: B, ) -> impl Future<Output = Result<B>> + Send

fn flush(&mut self) -> impl Future<Output = Result<()>> + Send

fn shutdown(&mut self) -> impl Future<Output = Result<()>> + Send

Implementors

impl VortexWrite for FileWrite

impl VortexWrite for ObjectStoreWrite

impl<W: AsyncWrite + Unpin + Send> VortexWrite for AsyncWriteAdapter<W>

impl<W: VortexWrite> VortexWrite for Compat<W>

Compatibility adapter for VortexWrite implementations that are based on Tokio.