async-pcap 0.1.0

An asynchronous implementation of pcap.
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
27
28
29
30
31
32
33
34
35
36
37
38
39

use async_pcap::{AsyncCapture, Capture, Device};
use tokio::runtime::Runtime;

fn main() {
    let rt = Runtime::new().unwrap();

    rt.block_on(async {
        // Open the network device
        let device = Device::lookup().unwrap().unwrap();
        let cap = Capture::from_device(device)
            .unwrap()
            .promisc(true)
            .snaplen(65535)
            .timeout(500)
            .immediate_mode(true)
            .open()
            .unwrap();

        // Create the async capture and handle
        let (async_cap, handle) = AsyncCapture::new(cap);

        // Clone the handle to stop from another task
        let handle_clone = handle.clone();

        // Spawn a task to stop capture after 5 seconds
        tokio::spawn(async move {
            tokio::time::sleep(std::time::Duration::from_secs(5)).await;
            handle_clone.stop(); // This sends the Stop signal
            println!("Capture stopped from another task");
        });

        // Read packets asynchronously
        while let Some(packet) = async_cap.next_packet().await {
            println!("Captured packet: {} bytes", packet.data.len());
        }

        println!("Capture loop exited cleanly");
    });
}