avr-tester 0.6.3

mod waker;

use self::waker::*;
use super::*;
use std::cell::RefCell;
use std::fmt;
use std::pin::Pin;
use std::rc::Rc;
use std::task::Context;

pub struct ComponentController {
    component: Pin<Box<dyn Future<Output = ()>>>,
    state: Rc<RefCell<ComponentState>>,
}

impl ComponentController {
    pub fn new(
        component: impl Future<Output = ()> + 'static,
    ) -> (Self, ComponentHandle) {
        let state = Rc::new(RefCell::new(ComponentState::Working));

        let controller = Self {
            component: Box::pin(component),
            state: state.clone(),
        };

        let handle = ComponentHandle::new(state);

        (controller, handle)
    }

    pub fn run(&mut self) -> ComponentControllerResult {
        match *self.state.borrow() {
            ComponentState::Working => {
                //
            }
            ComponentState::Paused => {
                return ComponentControllerResult::KeepComponent;
            }
            ComponentState::Removed => {
                return ComponentControllerResult::RemoveComponent;
            }
        }

        let waker = waker();
        let mut cx = Context::from_waker(&waker);

        if self.component.as_mut().poll(&mut cx).is_ready() {
            ComponentControllerResult::RemoveComponent
        } else {
            ComponentControllerResult::KeepComponent
        }
    }
}
impl fmt::Debug for ComponentController {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("ComponentController")
            .field("state", &self.state)
            .finish()
    }
}

pub enum ComponentControllerResult {
    KeepComponent,
    RemoveComponent,
}