noticeable 0.2.0

A library for lazy observables
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::callback::Callback;
use std::sync::{Arc, Mutex, Weak};

/// Handle type that represents the scope of the callback.
pub struct Subscriber<'a, E> {
    callback: Arc<Mutex<Callback<'a, E>>>,
}

impl<'a, E> Subscriber<'a, E> {
    pub(crate) fn new(callback: impl FnMut(&E) + Send + 'a) -> Self {
        Self {
            callback: Arc::new(Mutex::new(Callback::new(callback))),
        }
    }

    pub(crate) fn callback(&self) -> Weak<Mutex<Callback<'a, E>>> {
        Arc::downgrade(&self.callback)
    }
}