commonware-runtime 0.0.62

Execute asynchronous tasks with a configurable scheduler.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//! Helper for storing and retrieving context in thread-local storage.

use std::{any::Any, cell::RefCell};

thread_local! {
    static CONTEXT: RefCell<Option<Box<dyn Any + Send>>> = RefCell::new(None);
}

/// Set the context value
pub(crate) fn set<C: Send + 'static>(context: C) {
    CONTEXT.with(|cell| {
        *cell.borrow_mut() = Some(Box::new(context));
    });
}

/// Get the context value
pub fn get<C: Send + 'static>() -> C {
    CONTEXT.with(|cell| {
        // Attempt to take the context from the thread-local storage
        let mut borrow = cell.borrow_mut();
        match borrow.take() {
            Some(context) => {
                // Convert the context back to the original type
                let context = context.downcast::<C>().expect("failed to downcast context");
                *context
            }
            None => panic!("no context set"),
        }
    })
}

/// Clear the context value
pub(crate) fn clear() {
    CONTEXT.with(|cell| {
        *cell.borrow_mut() = None;
    });
}