Struct MultiplexPool 

pub struct MultiplexPool<R: Send + Sync> { /* private fields */ }

Shared resources with non-cloneable use reservations. The protocol owner validates and activates reservations while committing the actual operation.

Implementations

impl<R: Send + Sync> MultiplexPool<R>

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

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

pub fn begin_close(&self)

pub fn stats(&self) -> Stats

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

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

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

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

Trait Implementations

impl<R: Send + Sync> Clone for MultiplexPool<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 + Sync> Pool for MultiplexPool<R>

type Permit = MultiplexReservation<R>

type BuildPermit = MultiplexBuildPermit<R>

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

fn begin_close(&self)

fn stats(&self) -> Stats