flo_stream 0.7.1

Pubsub and related streams for Rust futures
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::sync::atomic::{AtomicUsize, Ordering};

///
/// Unique identifier for a subscriber to a publisher
///
#[derive(Clone, Copy, PartialEq, PartialOrd, Eq, Ord, Hash)]
pub (crate) struct SubscriberHandle(usize);

impl SubscriberHandle {
    ///
    /// Creates a new subscriber handle (which will be unique and different to any other)
    ///
    pub fn new() -> Self {
        static NEXT_HANDLE: AtomicUsize = AtomicUsize::new(0);

        let handle = NEXT_HANDLE.fetch_add(1, Ordering::Relaxed);

        Self(handle)
    }
}