crb-agent 0.0.35

CRB | Composable Runtime Blocks | Agent
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
38
39
40
41
42
43
44
45

use crate::address::{Address, MessageFor};
use crate::agent::Agent;
use crate::context::Context;
use anyhow::Result;
use async_trait::async_trait;
use crb_runtime::{InterruptionLevel, Interruptor};

impl<A: Agent> Address<A> {
    pub fn interrupt(&self) -> Result<()> {
        self.send(Interrupt)
    }
}

struct Interrupt;

#[async_trait]
impl<A: Agent> MessageFor<A> for Interrupt {
    async fn handle(self: Box<Self>, agent: &mut A, ctx: &mut Context<A>) -> Result<()> {
        let name = std::any::type_name::<A>();
        log::trace!("Interrupting agent: {name}");
        agent.interrupt(ctx);
        Ok(())
    }
}

impl<A: Agent> Interruptor for Address<A> {
    fn interrupt(&self) {
        self.interrupt_with_level(InterruptionLevel::FLAG);
    }

    fn interrupt_with_level(&self, level: InterruptionLevel) {
        if level >= InterruptionLevel::EVENT {
            // 0 - Interrupts an actor
            Address::interrupt(self).ok();
        }
        if level >= InterruptionLevel::FLAG {
            // 1 - Interrupts a state-machine
            self.stopper().stop(false);
        }
        if level >= InterruptionLevel::ABORT {
            // 2 - Interrupts an async routine
            self.stopper().stop(true);
        }
    }
}