Struct ReadStreamQueue 

pub struct ReadStreamQueue<const BUFFER_SIZE: usize> { /* private fields */ }

Implementations

impl<const BUFFER_SIZE: usize> ReadStreamQueue<BUFFER_SIZE>

pub fn new(read_half: OwnedReadHalf) -> Self

pub fn close(self) -> (OwnedReadHalf, Box<[u8]>)

pub async fn next_packet(&mut self) -> PacketReadableResult<()>

Trait Implementations

impl<const BUFFER_SIZE: usize> From<OwnedReadHalf> for ReadStreamQueue<BUFFER_SIZE>

fn from(read_half: OwnedReadHalf) -> Self

Converts to this type from the input type.

impl<const BUFFER_SIZE: usize> From<ReadStreamQueue<BUFFER_SIZE>> for OwnedReadHalf

fn from(queue: ReadStreamQueue<BUFFER_SIZE>) -> Self

Converts to this type from the input type.

impl<const BUFFER_SIZE: usize> InputPacketBytes for ReadStreamQueue<BUFFER_SIZE>

fn take_byte<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = InputPacketBytesResult<u8>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn take_slice<'life0, 'life1, 'async_trait>( &'life0 mut self, slice: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = InputPacketBytesResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn take_vec<'life0, 'life1, 'async_trait>( &'life0 mut self, vec: &'life1 mut Vec<u8>, count: usize, ) -> Pin<Box<dyn Future<Output = InputPacketBytesResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn has_bytes(&self, count: usize) -> bool

fn remaining_bytes(&self) -> usize