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

use cerk::kernel::BrokerEvent;
use cerk::runtime::channel::Receiver as CerkReceiver;
use std::sync::mpsc::Receiver;
use std::time::Duration;

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

impl ThreadingReceiver {
    #[allow(missing_docs)]
    pub fn new(receiver: Receiver<BrokerEvent>) -> Self {
        ThreadingReceiver { receiver }
    }
}

impl CerkReceiver for ThreadingReceiver {
    fn receive(&self) -> BrokerEvent {
        self.receiver.recv().unwrap()
    }
    fn receive_timeout(&self, timeout: Duration) -> Option<BrokerEvent> {
        match self.receiver.recv_timeout(timeout) {
            Ok(msg) => Some(msg),
            Err(_) => None,
        }
    }
}