Struct BufferPool 

pub struct BufferPool<T> { /* private fields */ }

Implementations

impl<T> BufferPool<T>

pub fn from_buffers(buffers: Vec<T>) -> Self

Build a pool from a pre-allocated set of buffers. The number of buffers fixes the pool’s capacity; the pool never grows.

pub fn capacity(&self) -> usize

pub fn available(&self) -> usize

Number of buffers currently available for acquisition.

pub fn outstanding(&self) -> usize

Number of buffers currently checked out (capacity − available).

pub fn try_acquire(&self) -> Option<PooledBuffer<T>>

Try to acquire one buffer. Returns None if the pool is exhausted.

pub fn try_acquire_or_err(&self) -> Result<PooledBuffer<T>, G2gError>

Sync convenience: acquire one buffer, or fail with PoolExhausted. Prefer Self::acquire inside async element loops — it awaits capacity instead of failing fast.

pub fn acquire(&self) -> AcquireFuture<'_, T>

Acquire one buffer, awaiting until one becomes available.

impl BufferPool<Box<[u8]>>

pub fn new_byte_pool(count: usize, bytes: usize) -> Self

Allocate a CPU byte pool of count buffers, each bytes long.

Trait Implementations

impl<T> Clone for BufferPool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for BufferPool<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.