tinybase 0.1.5

A tiny embedded database built in Rust.
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 std::sync::mpsc::Receiver;

use crate::{table::SenderMap, Record};

#[derive(Clone)]
pub(crate) enum Event<T> {
    Remove(Record<T>),
    Insert(Record<T>),
    Update { id: u64, old_data: T, new_data: T },
}

pub(crate) struct Subscriber<T> {
    id: u64,
    pub rx: Receiver<Event<T>>,
    senders: SenderMap<Event<T>>,
}

impl<T> Subscriber<T> {
    pub fn new(id: u64, rx: Receiver<Event<T>>, senders: SenderMap<Event<T>>) -> Self {
        Self { id, rx, senders }
    }
}

impl<T> Drop for Subscriber<T> {
    fn drop(&mut self) {
        self.senders.write().unwrap().remove(&self.id);
    }
}