autoschematic-core 0.8.2

Core shared functionality for Autoschematic: workflow engine, state management, and Git integrations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::time::Duration;

use anyhow::bail;
use tokio::sync::mpsc::error::TryRecvError;

use crate::aux_task::{TaskInbox, message::TaskRegistryMessage};

pub async fn drain_inbox(inbox: &mut TaskInbox) -> anyhow::Result<()> {
    loop {
        let res = inbox.try_recv();
        tracing::error!("{:?}", res);
        match res {
            Ok(TaskRegistryMessage::ShutDown) => {
                bail!("Shutting down task...")
            }
            Err(TryRecvError::Empty) => return Ok(()),
            Err(e) => return Err(e.into()),
            _ => {}
        }
        tokio::time::sleep(Duration::from_secs(0)).await;
    }
}