Struct gain::stream::RecvWriteStream

pub struct RecvWriteStream { /* fields omitted */ }

Bidirectional stream.

Implementations

impl RecvWriteStream

pub fn split(self) -> (RecvStream, WriteStream)

Split the stream into unidirectional parts.

pub fn split3(self) -> (RecvOnlyStream, WriteOnlyStream, CloseStream)

Split the stream into unidirectional parts which can be closed asynchronously. The single CloseStream closes both directions.

Trait Implementations

impl Close for RecvWriteStream

fn close(&mut self) -> Close

Close a stream. Returns a future.

impl Default for RecvWriteStream

fn default() -> Self

Returns the “default value” for a type.

impl Drop for RecvWriteStream

fn drop(&mut self)

Executes the destructor for this type.

impl From<RecvWriteStream> for ReadWriteStream

fn from(stream: RecvWriteStream) -> Self

Performs the conversion.

impl From<RecvWriteStream> for RecvStream

fn from(stream: RecvWriteStream) -> Self

Performs the conversion.

impl From<RecvWriteStream> for WriteStream

fn from(stream: RecvWriteStream) -> Self

Performs the conversion.

impl Recv for RecvWriteStream

fn recv<R>(&mut self, capacity: usize, receptor: R) -> Recv<'_, R> where
    R: Fn(&[u8], i32) -> usize + Unpin, 

Receive data packets repeatedly. Returns a future.

impl Write for RecvWriteStream

fn write<'a>(&'a mut self, data: &'a [u8]) -> Write<'_>

Write part of a byte slice. Returns a future.

fn write_note<'a>(&'a mut self, data: &'a [u8], note: i32) -> Write<'_>

Write part of a byte slice. Returns a future.

fn write_all<'a>(&'a mut self, data: &'a [u8]) -> WriteAll<'_>

Write a whole byte slice. Returns a future.