pubsub-tokio 1.0.0

Fun-out pattern implementation based on tokio mpsc channels
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

#![cfg(any(test, feature = "testing"))]
use std::sync::atomic::AtomicBool;

static INITIALIZED: AtomicBool = AtomicBool::new(false);

pub fn init_test() {
    if INITIALIZED
        .compare_exchange(
            false,
            true,
            std::sync::atomic::Ordering::Relaxed,
            std::sync::atomic::Ordering::Relaxed,
        )
        .is_ok()
    {
        tracing_subscriber::fmt()
            .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
            .with_thread_ids(true)
            .with_thread_names(true)
            .with_line_number(true)
            .init();
    }
}