Struct pi_async_buffer::ByteBuffer

source · [−]

pub struct ByteBuffer { /* private fields */ }

Expand description

异步字节缓冲区

Implementations

source

impl ByteBuffer

source

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

创建一个异步字节缓冲区

source

pub fn is_terminated(&self) -> bool

获取当前流是否已终止

source

pub fn is_empty(&self) -> bool

判断当前缓冲区是否为空

source

pub fn len(&self) -> usize

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

source

pub fn remaining(&self) -> usize

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

source

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

异步获取一个i8

source

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

异步获取一个u8

source

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

异步获取一个大端i16

source

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

异步获取一个小端i16

source

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

异步获取一个大端u16

source

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

异步获取一个小端u16

source

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

异步获取一个大端i32

source

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

异步获取一个小端i32

source

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

异步获取一个大端u32

source

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

异步获取一个小端u32

source

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

异步获取一个大端i64

source

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

异步获取一个小端i64

source

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

异步获取一个大端u64

source

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

异步获取一个小端u64

source

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

异步获取一个大端i128

source

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

异步获取一个小端i128

source

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

异步获取一个大端u128

source

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

异步获取一个小端u128

source

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

异步获取一个大端isize

source

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

异步获取一个小端isize

source

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

异步获取一个大端usize

source

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

异步获取一个小端usize

source

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

异步获取一个大端f32

source

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

异步获取一个小端f32

source

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

异步获取一个大端f64

source

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

异步获取一个小端f64

source

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

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

Trait Implementations

source

impl AsRef<[u8]> for ByteBuffer

source

fn as_ref(&self) -> &[u8]ⓘNotable traits for &[u8]`impl Read for &[u8]impl Write for &mut [u8]`

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

source

impl Send for ByteBuffer

source

impl !Sync for ByteBuffer

Auto Trait Implementations

impl !RefUnwindSafe for ByteBuffer

impl Unpin for ByteBuffer

impl !UnwindSafe for ByteBuffer

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::<T>()

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Struct pi_async_buffer::ByteBuffer

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 async fn get_i8(&mut self) -> Option<i8>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Trait Implementations

impl AsRef<[u8]> for ByteBuffer

fn as_ref(&self) -> &[u8]ⓘNotable traits for &[u8]impl Read for &[u8]impl Write for &mut [u8]

impl Send for ByteBuffer

impl !Sync for ByteBuffer

Auto Trait Implementations

impl !RefUnwindSafe for ByteBuffer

impl Unpin for ByteBuffer

impl !UnwindSafe for ByteBuffer

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for T where U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::<T>()

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

fn as_ref(&self) -> &[u8]ⓘNotable traits for &[u8]`impl Read for &[u8]impl Write for &mut [u8]`

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,