lib/
lib.rs

1use futures::StreamExt;
2use pidcat::source::*;
3use pidcat::LogStream;
4
5#[tokio::main]
6async fn main() {
7    let source = ADBSource::new(None);
8
9    let mut logs: LogStream = source.source().await;
10
11    while let Some(r) = logs.next().await {
12        if let Ok(log) = r {
13            println!("{}", log);
14        }
15    }
16}