CarlosLanderas

use anyhow::Result;
use std::sync::Arc;
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<()> {

    let (tx, rx) = std::sync::mpsc::channel();
    let cts = Arc::new(cancellation::CancellationTokenSource::new());
    let cts_clone = cts.clone();