toplevel/
toplevel.rs

1use std::time::Duration;
2use tokio::{sync::{mpsc, oneshot}, time::sleep};
3use wayland_protocols_async::zwlr_foreign_toplevel_management_v1::handler::{ToplevelHandler, ToplevelMessage};
4
5#[tokio::main]
6async fn main() {
7    // create mpsc channel for interacting with the toplevel handler
8    let (toplevel_msg_tx, mut toplevel_msg_rx) = mpsc::channel(128);
9
10    // create mpsc channel for receiving events from the toplevel handler
11    let (toplevel_event_tx, mut toplevel_event_rx) = mpsc::channel(128);
12    
13    // create the handler instance
14    let mut toplevel_handler = ToplevelHandler::new(toplevel_event_tx);
15
16
17    // start the toplevel handler
18    let toplevel_t = tokio::spawn(async move {
19        let _ = toplevel_handler.run(toplevel_msg_rx).await;
20    });
21
22    // receive all toplevel events
23    let toplevel_event_t = tokio::spawn(async move {
24        loop {
25            let msg = toplevel_event_rx.recv().await;
26            if msg.is_none() {
27                continue;
28            }
29            println!("received toplevel_event event={:?}", msg);
30        }
31    });
32
33    // send an event
34    let toplevel_send_t = tokio::spawn(async move {
35        let _ =sleep(Duration::from_secs(5)).await;
36        let (tx, rx) = oneshot::channel();
37        let _ =toplevel_msg_tx.send(ToplevelMessage::GetToplevels { reply_to: tx }).await;
38
39        let res = rx.await.expect("no reply from toplevel handler");
40        println!("received all toplevels ({:?})", res);
41    });
42
43    let _ = toplevel_t.await.unwrap();
44    let _ = toplevel_event_t.await.unwrap();
45    let _ = toplevel_send_t.await.unwrap();
46}
toplevel/toplevel.rs

toplevel/
toplevel.rs
