cerk_runtime_threading 0.2.11

This is a package for CERK. CERK is an open source CloudEvents Router written in Rust with a MicroKernel architecture.
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
46
47
48
49

use cerk::kernel::BrokerEvent;
use cerk::runtime::channel::Sender as CerkSender;
use std::sync::mpsc::{Sender, SyncSender};

/// Implementation for `cerk::runtime::channel::Sender` that uses `std::sync::mpsc::SyncSender` channel sender.
pub struct ThreadingSender {
    sender: SyncSender<BrokerEvent>,
}

impl ThreadingSender {
    #[allow(missing_docs)]
    pub fn new(sender: SyncSender<BrokerEvent>) -> Self {
        return ThreadingSender { sender };
    }
}

impl CerkSender for ThreadingSender {
    fn send(&self, event: BrokerEvent) {
        self.sender.send(event).unwrap();
    }
    fn clone_boxed(&self) -> Box<dyn CerkSender + Send> {
        Box::new(ThreadingSender {
            sender: self.sender.clone(),
        })
    }
}

/// Implementation for `cerk::runtime::channel::Sender` that uses `std::sync::mpsc::Sender` channel sender.
pub struct ThreadingKernelSender {
    sender: Sender<BrokerEvent>,
}

impl ThreadingKernelSender {
    #[allow(missing_docs)]
    pub fn new(sender: Sender<BrokerEvent>) -> Self {
        return ThreadingKernelSender { sender };
    }
}

impl CerkSender for ThreadingKernelSender {
    fn send(&self, event: BrokerEvent) {
        self.sender.send(event).unwrap();
    }
    fn clone_boxed(&self) -> Box<dyn CerkSender + Send> {
        Box::new(ThreadingKernelSender {
            sender: self.sender.clone(),
        })
    }
}