Struct SemaphorePermits 

pub struct SemaphorePermits { /* private fields */ }

Semaphore-based backpressure implementation.

Enforces a maximum number of bytes that can be buffered at once. When the limit is reached, acquire() will block until space is available. Acquires all N bytes in a single atomic operation (O(1), not O(N)).

Example

use monocoque_core::backpressure::{BytePermits, SemaphorePermits};

// Allow up to 10MB of buffered data
let permits = SemaphorePermits::new(10 * 1024 * 1024);

// Acquire permit for 1KB write
let permit = permits.acquire(1024).await;
// ... perform write ...
drop(permit); // releases 1024 bytes back to the pool

Implementations

impl SemaphorePermits

pub fn new(max_bytes: usize) -> Self

Create a new semaphore-based backpressure controller.

Arguments

• max_bytes - Maximum number of bytes that can be buffered

Trait Implementations

impl BytePermits for SemaphorePermits

fn acquire<'life0, 'async_trait>( &'life0 self, n_bytes: usize, ) -> Pin<Box<dyn Future<Output = Permit> + Send + 'async_trait>>

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

Acquire permission to write n_bytes.

impl Clone for SemaphorePermits

fn clone(&self) -> SemaphorePermits

Returns a duplicate of the value.

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

Performs copy-assignment from source.