theater 0.3.13

A WebAssembly actor system for AI agents
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

use std::collections::HashMap;
use std::sync::{Arc, Mutex};
use theater::ActorOperation;
use tokio::sync::mpsc;

/// Mock actor handle for testing
pub struct MockActorHandle {
    operation_tx: mpsc::Sender<ActorOperation>,
    response_map: Arc<Mutex<HashMap<String, Vec<u8>>>>,
}

impl MockActorHandle {
    pub fn new() -> (Self, mpsc::Receiver<ActorOperation>) {
        let (tx, rx) = mpsc::channel(10);
        (
            Self {
                operation_tx: tx,
                response_map: Arc::new(Mutex::new(HashMap::new())),
            },
            rx,
        )
    }

    pub fn with_response(self, operation: &str, response: Vec<u8>) -> Self {
        self.response_map
            .lock()
            .unwrap()
            .insert(operation.to_string(), response);
        self
    }

    pub fn get_sender(&self) -> mpsc::Sender<ActorOperation> {
        self.operation_tx.clone()
    }
}