Struct SingleplexPool 

pub struct SingleplexPool<R: Send> { /* private fields */ }

Exclusive resource ownership. Resources need Send, without requiring Sync. Clean reuse is an explicit lease release; unfinished lease drop retires it.

Implementations

impl<R: Send> SingleplexPool<R>

pub fn new(options: Options) -> Result<Self, Error>

pub async fn acquire_or_reserve( &self, cancel: &Cancellation, ) -> Result<Acquisition<SingleplexLease<R>, SingleplexBuildPermit<R>>, Error>

pub fn begin_close(&self)

pub fn stats(&self) -> Stats

pub fn prune(&self, retain: usize) -> usize

Retire unused registrations until at most retain live resources remain, or until only in-use resources remain. No I/O occurs here.

pub fn try_retirement(&self) -> Option<Retirement<R>>

pub async fn next_retirement( &self, cancel: &Cancellation, ) -> Result<Option<Retirement<R>>, Error>

Wait for cleanup work; None means admission is closed and all resources and construction/retirement obligations have finished.

pub async fn wait_closed(&self, cancel: &Cancellation) -> Result<(), Error>

Call begin_close, finish active work and drain retirements concurrently. This waits for acknowledgments; it does not execute resource cleanup.

Trait Implementations

impl<R: Send> Clone for SingleplexPool<R>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R: Send> Pool for SingleplexPool<R>

type Permit = SingleplexLease<R>

type BuildPermit = SingleplexBuildPermit<R>

async fn acquire_or_reserve( &self, cancel: &Cancellation, ) -> Result<Acquisition<Self::Permit, Self::BuildPermit>, Error>

fn begin_close(&self)

fn stats(&self) -> Stats