ari-subscriber 0.0.2

Async Executor Instrumentation Observability Utility A tracing subscriber layer that outputs Tokio's tracing instrumentation to the terminal in a format conducive to debugging.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use std::{sync::Arc, time::Duration};

use tokio::sync::Barrier;
use tracing_subscriber::prelude::*;

use ari_subscriber::Layer;

#[tokio::main]
async fn main() {
    let layer = Layer::new();

    tracing_subscriber::registry().with(layer).init();

    let barrier = Arc::new(Barrier::new(2));

    let barrier1 = barrier.clone();
    let jh = tokio::spawn(async move {
        tokio::time::sleep(Duration::from_millis(100)).await;
        barrier1.wait().await;
    });

    barrier.wait().await;

    jh.await.unwrap();
}