Struct AsyncFactoryContext 

pub struct AsyncFactoryContext { /* private fields */ }

Handle for propagating the async resolution chain into detached tasks.

Obtained from ServiceProvider::async_context inside an async factory (the call captures the current chain synchronously). Clone it into a spawned task and resolve through it; self/cross dependency cycles across tasks are then reported as RdiError::CircularDependency instead of dead-locking.

.async_singleton(|sp| Box::pin(async move {
    let ctx = sp.async_context().expect("built provider");
    let worker = tokio::spawn({
        let ctx = ctx.clone();
        async move { ctx.get_async::<Dep>().await }
    });
    let dep = worker.await.unwrap().unwrap();
    Arc::new(Service { dep })
}))

Implementations

impl AsyncFactoryContext

pub fn provider(&self) -> &Arc<ServiceProvider>

The container this context resolves from.

pub fn get_async<T: ?Sized + Send + Sync + 'static>( &self, ) -> impl Future<Output = Result<Arc<T>, RdiError>> + Send + 'static

Resolve an async service, extending the propagated resolution chain.

pub fn get_keyed_async<T: ?Sized + Send + Sync + 'static>( &self, key: impl Into<ServiceKey> + Send + 'static, ) -> impl Future<Output = Result<Arc<T>, RdiError>> + Send + 'static

Resolve an async keyed service, extending the propagated resolution chain.

Trait Implementations

impl Clone for AsyncFactoryContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.