examples/gio_futures_await: Add CancellableFuture example

Handle SIGINT via the unix signal future and cancellation via the
CancellableFuture

Author: 3v1n0

Cargo.lock

@@ -9,6 +9,7 @@ version.workspace = true
 futures = "0.3"
 futures-channel = "0.3"
 futures-util = "0.3"
+libc = "0.2"
 glib.workspace = true
 gio.workspace = true
 

examples/Cargo.toml

@@ -1,30 +1,41 @@
-use std::str;
-
 use futures::prelude::*;
 use gio::prelude::*;
 use glib::clone;
 
 fn main() {
     let c = glib::MainContext::default();
-    let l = glib::MainLoop::new(Some(&c), false);
-
     let file = gio::File::for_path("Cargo.toml");
+    let cancellable = gio::Cancellable::new();
 
     let future = clone!(
         #[strong]
-        l,
+        cancellable,
         async move {
             match read_file(file).await {
                 Ok(()) => (),
                 Err(err) => eprintln!("Got error: {err}"),
             }
-            l.quit();
+            cancellable.cancel();
         }
     );
 
-    c.spawn_local(future);
-
-    l.run();
+    let _ = c
+        .block_on(c.spawn_local(gio::CancellableFuture::new(
+            futures_util::future::join(
+                future,
+                clone!(
+                    #[strong]
+                    cancellable,
+                    async move {
+                        glib::unix_signal_future(libc::SIGINT).await;
+                        eprintln!("Ctrl+C pressed, operation will be stopped!");
+                        cancellable.cancel();
+                    }
+                ),
+            ),
+            cancellable,
+        )))
+        .expect("futures must be executed");
 }
 
 /// Throughout our chained futures, we convert all errors to strings