timely_communication 0.29.0

Communication layer for timely dataflow
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! A helper struct to report when something has been dropped.

use std::rc::Rc;
use std::cell::RefCell;

/// An opaque type that reports when it is dropped.
pub struct Canary {
    index: usize,
    queue: Rc<RefCell<Vec<usize>>>,
}

impl Canary {
    /// Allocates a new drop canary.
    pub fn new(index: usize, queue: Rc<RefCell<Vec<usize>>>) -> Self {
        Canary { index, queue }
    }
}

impl Drop for Canary {
    fn drop(&mut self) {
        self.queue.borrow_mut().push(self.index);
    }
}