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

use crate::{Edit, Patch};
use parking_lot::Mutex;
use std::{
    mem,
    sync::{Arc, Weak},
};

#[derive(Default)]
pub struct Topic(Mutex<Vec<Weak<Mutex<Patch<usize>>>>>);

pub struct Subscription(Arc<Mutex<Patch<usize>>>);

impl Topic {
    pub fn subscribe(&mut self) -> Subscription {
        let subscription = Subscription(Default::default());
        self.0.get_mut().push(Arc::downgrade(&subscription.0));
        subscription
    }

    pub fn publish(&self, edits: impl Clone + IntoIterator<Item = Edit<usize>>) {
        publish(&mut *self.0.lock(), edits);
    }

    pub fn publish_mut(&mut self, edits: impl Clone + IntoIterator<Item = Edit<usize>>) {
        publish(self.0.get_mut(), edits);
    }
}

impl Subscription {
    pub fn consume(&self) -> Patch<usize> {
        mem::take(&mut *self.0.lock())
    }
}

fn publish(
    subscriptions: &mut Vec<Weak<Mutex<Patch<usize>>>>,
    edits: impl Clone + IntoIterator<Item = Edit<usize>>,
) {
    subscriptions.retain(|subscription| {
        if let Some(subscription) = subscription.upgrade() {
            let mut patch = subscription.lock();
            *patch = patch.compose(edits.clone());
            true
        } else {
            false
        }
    });
}