mtlog-tokio 0.4.0

use std::sync::mpsc::channel;

use mtlog_tokio::logger_config;

#[tokio::main]
async fn main() {
    // main thread log to stdout only
    logger_config()
        .with_name("main thread")
        .scope_global(async move {
            log::info!("Hello, world!");
            // threaded tasks log to files
            let (handles, senders): (Vec<_>, Vec<_>) = (0..5)
                .map(|i| {
                    let (sender, receiver) = channel::<&'static str>();
                    (
                        tokio::spawn(async move {
                            logger_config()
                                .with_name(&format!("thread {i}"))
                                .with_log_file(format!("/tmp/thread_{i}.log"))
                                .unwrap()
                                .scope_local(async move {
                                    for message in receiver {
                                        log::warn!("MESSAGE RECEIVED: {message}");
                                    }
                                })
                                .await;
                        }),
                        sender,
                    )
                })
                .unzip();
            for sender in senders {
                sender.send("Hello, world!").unwrap();
            }
            for handle in handles {
                handle.await.unwrap();
            }
            for i in 0..5 {
                log::info!(
                    "last line of /tmp/thread_{i}.log is:\n\t{}",
                    std::fs::read_to_string(format!("/tmp/thread_{i}.log"))
                        .unwrap()
                        .trim_end()
                        .lines()
                        .last()
                        .unwrap()
                );
            }
        })
        .await;
}