driftdb 0.1.4

A real-time data backend for browser-based applications (core library).
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

use crate::types::MessageFromDatabase;
use std::{
    collections::VecDeque,
    sync::{Arc, Mutex},
};

pub struct MessageStash {
    messages: Arc<Mutex<VecDeque<MessageFromDatabase>>>,
}

impl MessageStash {
    pub fn new() -> (MessageStash, impl Fn(&MessageFromDatabase)) {
        let stash = MessageStash {
            messages: Arc::new(Mutex::new(VecDeque::new())),
        };

        let callback = {
            let messages = stash.messages.clone();
            move |message: &MessageFromDatabase| {
                messages.lock().unwrap().push_back(message.clone());
            }
        };

        (stash, callback)
    }

    pub fn next(&self) -> Option<MessageFromDatabase> {
        self.messages.lock().unwrap().pop_front()
    }
}