Struct gain::stream::buf::ReadWriteStream

pub struct ReadWriteStream { /* fields omitted */ }

Bidirectional stream with input buffering.

Implementations

impl ReadWriteStream

pub fn new(stream: RecvWriteStream) -> Self

Convert an unbuffered stream into a stream with input buffering.

pub fn with_read_capacity(capacity: usize, stream: RecvWriteStream) -> Self

Convert an unbuffered stream into a stream with custom input buffer size.

Trait Implementations

impl Close for ReadWriteStream

fn close(&mut self) -> Close

Close a stream. Returns a future.

impl Default for ReadWriteStream

fn default() -> Self

Returns the “default value” for a type.

impl From<RecvWriteStream> for ReadWriteStream

fn from(stream: RecvWriteStream) -> Self

Performs the conversion.

impl Read for ReadWriteStream

fn read<'a>(&'a mut self, dest: &'a mut [u8]) -> Read<'_>

Read some bytes into a slice. Returns a future.

fn buf_read<'a, R, T>(
    &'a mut self,
    min_read: usize,
    receptor: R
) -> BufRead<'a, R, T> where
    R: FnOnce(&mut Buf) -> T + Unpin,
    T: Default, 

Read buffered data. Returns a future.

impl Write for ReadWriteStream

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.