bctx-conductor 0.1.22

bctx-conductor — Spiral Cycle agent runtime, SignalGraph, PassageRun
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

use super::envelope::Envelope;
use std::collections::VecDeque;

pub struct Channel {
    pub name: String,
    pub queue: VecDeque<Envelope>,
}

impl Channel {
    pub fn new(name: impl Into<String>) -> Self {
        Self {
            name: name.into(),
            queue: VecDeque::new(),
        }
    }
    pub fn push(&mut self, e: Envelope) {
        self.queue.push_back(e);
    }
    pub fn pop(&mut self) -> Option<Envelope> {
        self.queue.pop_front()
    }
    pub fn len(&self) -> usize {
        self.queue.len()
    }
    pub fn is_empty(&self) -> bool {
        self.queue.is_empty()
    }
}