Method new

library/src/adapters/database.rs:25–29

Creation of context manager returns context manager AND event receiver

()

impl ContextManager {
    /// Creation of context manager returns context manager AND event receiver
    pub async fn new() -> (Arc<RwLock<Self>>, Receiver<Box<dyn Message>>) {
        let pool = connection_pool().await;
        let (sender, receiver) = channel(20);
        (Arc::new(RwLock::new(Self { pool, sender })), receiver)
    }
    pub fn executor(&self) -> Arc<RwLock<Executor>> {
        RwLock::new(Executor::new(self.pool)).into()
    }