kad 0.6.1

A generic / futures based implementation of the Kademlia Distributed Hash Table (DHT)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::{Arc, Mutex};

/// Synchronous structure used for testing
#[derive(Debug, Clone)]
pub struct MockSync(Arc<Mutex<u64>>);

impl MockSync {
    pub fn new(v: u64) -> Self {
        MockSync(Arc::new(Mutex::new(v)))
    }
}

impl PartialEq for MockSync {
    fn eq(&self, o: &Self) -> bool {
        let v1 = { self.0.lock().unwrap().clone() };
        let v2 = { o.0.lock().unwrap().clone() };
        v1 == v2
    }
}

unsafe impl Sync for MockSync {}