Struct cros_async::blocking::cancellable_pool::Inner

struct Inner {
    blocking_pool: BlockingPool,
    state: Mutex<State>,
    cancellables_cv: Condvar,
}

Fields

blocking_pool: BlockingPool

state: Mutex<State>

cancellables_cv: Condvar

This condvar gets notified when cancellables is empty after removing an entry.

Implementations

impl Inner

pub fn spawn<F, R>(self: &Arc<Self>, f: F) -> impl Future<Output = R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

fn add_cancellable(&self, cancel: Box<dyn Fn() + Send + 'static>) -> u64

Adds cancel to a cancellables and returns an id with which cancel can be accessed/removed.