ztopic 0.3.18

A topic-based pub/sub library for Rust
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
26

use std::time::Duration;

use anyhow::Result;
use tokio::task::JoinSet;

#[tokio::main]
async fn main() -> Result<()> {
    let mut join_set = JoinSet::new();

    join_set.spawn(async {
        loop {
            tokio::time::sleep(Duration::from_secs(1)).await;
            println!("hello")
        }
    });

    let join_set = Box::leak(Box::new(join_set));

    tokio::time::sleep(Duration::from_secs(3)).await;

    unsafe { std::ptr::drop_in_place(join_set) };

    tokio::time::sleep(Duration::from_secs(10)).await;

    Ok(())
}