Struct bird_protocol_server::read::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
    'life0: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

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

fn remaining_bytes(&self) -> usize