Trait StreamWriter 

pub trait StreamWriter<'a> {
    type Input: 'a;
    type Info;

    // Required methods
    fn info(&self) -> &Self::Info;
    fn write(
        &self,
        input: Self::Input,
    ) -> impl Future<Output = StreamResult<()>> + Send;
    fn close(self) -> impl Future<Output = StreamResult<()>> + Send;
    fn close_with_reason(
        self,
        reason: &str,
    ) -> impl Future<Output = StreamResult<()>> + Send;
}

Writer for an open data stream.

Required Associated Types

type Input: 'a

Type of input this writer accepts.

type Info

Information about the underlying data stream.

Required Methods

fn info(&self) -> &Self::Info

Returns a reference to the stream info.

fn write( &self, input: Self::Input, ) -> impl Future<Output = StreamResult<()>> + Send

Writes to the stream.

fn close(self) -> impl Future<Output = StreamResult<()>> + Send

Closes the stream normally.

fn close_with_reason( self, reason: &str, ) -> impl Future<Output = StreamResult<()>> + Send

Closes the stream abnormally, specifying the reason for closure.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

impl<'a> StreamWriter<'a> for ByteStreamWriter

type Input = &'a [u8]

type Info = ByteStreamInfo

impl<'a> StreamWriter<'a> for TextStreamWriter

type Input = &'a str

type Info = TextStreamInfo