Trait ipfs_sqlite_block_store::async_block_store::RuntimeAdapter

pub trait RuntimeAdapter: Clone + 'static {
    pub fn unblock<F, T>(self, f: F) -> BoxFuture<'static, Result<T>>
    where
        F: FnOnce() -> T + Send + 'static,
        T: Send + 'static;
    pub fn sleep(&self, duration: Duration) -> BoxFuture<'_, ()>;
}

Adapter for a runtime such as tokio or async_std

Required methods

pub fn unblock<F, T>(self, f: F) -> BoxFuture<'static, Result<T>> where
    F: FnOnce() -> T + Send + 'static,
    T: Send + 'static, 

run a blocking block of code, most likely involving IO, on a different thread.

pub fn sleep(&self, duration: Duration) -> BoxFuture<'_, ()>

sleep for the given duration

Loading content...

Implementors

Loading content...