Trait AsyncStreamSink 

pub trait AsyncStreamSink {
    type Error;

    // Required methods
    fn write_chunk<'operation>(
        &'operation mut self,
        input: &'operation [u8],
    ) -> impl Future<Output = Result<usize, Self::Error>> + Send + 'operation;
    fn commit(
        &mut self,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send + '_;
    fn abort(&mut self, partial: StreamPartialState);
}

Cross-thread asynchronous sink.

Required Associated Types

type Error

Sink-specific payload-free failure.

Required Methods

fn write_chunk<'operation>( &'operation mut self, input: &'operation [u8], ) -> impl Future<Output = Result<usize, Self::Error>> + Send + 'operation

Accepts some or all bytes in a Send future.

fn commit( &mut self, ) -> impl Future<Output = Result<(), Self::Error>> + Send + '_

Commits a successfully validated stream in a Send future.

fn abort(&mut self, partial: StreamPartialState)

Synchronously aborts on error or future cancellation.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors