Struct pi_async_buffer::ByteBuffer

pub struct ByteBuffer { /* private fields */ }

异步字节缓冲区

Implementations

impl ByteBuffer

pub fn new(stream: BoxReceiver<'static, Arc<Vec<u8>>>) -> Self

创建一个异步字节缓冲区

pub fn is_terminated(&self) -> bool

获取当前流是否已终止

pub fn is_empty(&self) -> bool

判断当前缓冲区是否为空

pub fn len(&self) -> usize

获取当前缓冲区包含的所有字节长度

pub fn remaining(&self) -> usize

获取当前缓冲区剩余可读字节长度

pub fn unreceived(&self) -> Option<usize>

流中已发送未接收的数据条目长度

pub fn readed(&self) -> usize

清理前已读字节的总数量

pub async fn get_i8(&mut self) -> Option<i8>

异步获取一个i8

pub async fn get_u8(&mut self) -> Option<u8>

异步获取一个u8

pub async fn get_i16(&mut self) -> Option<i16>

异步获取一个大端i16

pub async fn get_i16_le(&mut self) -> Option<i16>

异步获取一个小端i16

pub async fn get_u16(&mut self) -> Option<u16>

异步获取一个大端u16

pub async fn get_u16_le(&mut self) -> Option<u16>

异步获取一个小端u16

pub async fn get_i32(&mut self) -> Option<i32>

异步获取一个大端i32

pub async fn get_i32_le(&mut self) -> Option<i32>

异步获取一个小端i32

pub async fn get_u32(&mut self) -> Option<u32>

异步获取一个大端u32

pub async fn get_u32_le(&mut self) -> Option<u32>

异步获取一个小端u32

pub async fn get_i64(&mut self) -> Option<i64>

异步获取一个大端i64

pub async fn get_i64_le(&mut self) -> Option<i64>

异步获取一个小端i64

pub async fn get_u64(&mut self) -> Option<u64>

异步获取一个大端u64

pub async fn get_u64_le(&mut self) -> Option<u64>

异步获取一个小端u64

pub async fn get_i128(&mut self) -> Option<i128>

异步获取一个大端i128

pub async fn get_i128_le(&mut self) -> Option<i128>

异步获取一个小端i128

pub async fn get_u128(&mut self) -> Option<u128>

异步获取一个大端u128

pub async fn get_u128_le(&mut self) -> Option<u128>

异步获取一个小端u128

pub async fn get_isize(&mut self) -> Option<isize>

异步获取一个大端isize

pub async fn get_isize_le(&mut self) -> Option<isize>

异步获取一个小端isize

pub async fn get_usize(&mut self) -> Option<usize>

异步获取一个大端usize

pub async fn get_usize_le(&mut self) -> Option<usize>

异步获取一个小端usize

pub async fn get_f32(&mut self) -> Option<f32>

异步获取一个大端f32

pub async fn get_f32_le(&mut self) -> Option<f32>

异步获取一个小端f32

pub async fn get_f64(&mut self) -> Option<f64>

异步获取一个大端f64

pub async fn get_f64_le(&mut self) -> Option<f64>

异步获取一个小端f64

pub async fn get(&mut self, len: usize) -> Option<PartBuffer>

异步获取指定长度的部分缓冲区

pub async fn try_get(&mut self, len: usize) -> Option<PartBuffer>

尝试异步获取指定长度的部分缓冲区， 此方法保证不会导致异步阻塞，同时此方法也不保证一定可以获取到不小于指定长度的部分缓冲区 当指定获取的字节数量为0，表示尝试获取当前流和当前缓冲区中所有剩余的未读字节

pub fn truncate(&mut self) -> usize

截断当前所有已读缓冲区 这会释放已读缓冲区的内存，并重置已读字节的总数量

pub fn clear(&mut self)

清空当前缓冲区 这会释放当前缓冲区的所有内存，并重置已读字节的总数量

Trait Implementations

impl AsRef<[u8]> for ByteBuffer

fn as_ref(&self) -> &[u8]

Converts this type into a shared reference of the (usually inferred) input type.

impl Send for ByteBuffer

impl !Sync for ByteBuffer