Struct AsyncBlocker 

pub struct AsyncBlocker { /* private fields */ }

Available on crate feature asynchronous only.

Blocker that can be used to block in async code.

Implementations

impl AsyncBlocker

pub fn new(capacity: usize) -> AsyncBlocker

Create a new AsyncBlocker with the given capacity.

pub async fn wait(&mut self) -> Result<(), LogFSError>

Block and await the current task until a registered caller unblocks it.

Trait Implementations

impl Blocker for AsyncBlocker

fn unblocker(&self) -> Arc<dyn Unblocker>

Return an unblocker which can be called to unblock this blocker.

impl From<&AsyncBlocker> for Arc<dyn Unblocker>

fn from(blocker: &AsyncBlocker) -> Arc<dyn Unblocker>

Converts to this type from the input type.

impl From<AsyncBlocker> for Arc<dyn Unblocker>

fn from(blocker: AsyncBlocker) -> Arc<dyn Unblocker>

Converts to this type from the input type.