gdk4/
clipboard.rs

1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use std::{future, pin::Pin, ptr};
4
5use glib::{translate::*, GString};
6
7use crate::{ffi, prelude::*, Clipboard};
8
9impl Clipboard {
10    #[doc(alias = "gdk_clipboard_read_async")]
11    pub fn read_async<Q: FnOnce(Result<(gio::InputStream, GString), glib::Error>) + 'static>(
12        &self,
13        mime_types: &[&str],
14        io_priority: glib::Priority,
15        cancellable: Option<&impl IsA<gio::Cancellable>>,
16        callback: Q,
17    ) {
18        let main_context = glib::MainContext::ref_thread_default();
19        let is_main_context_owner = main_context.is_owner();
20        let has_acquired_main_context = (!is_main_context_owner)
21            .then(|| main_context.acquire().ok())
22            .flatten();
23        assert!(
24            is_main_context_owner || has_acquired_main_context.is_some(),
25            "Async operations only allowed if the thread is owning the MainContext"
26        );
27
28        let user_data: Box<glib::thread_guard::ThreadGuard<Q>> =
29            Box::new(glib::thread_guard::ThreadGuard::new(callback));
30        unsafe extern "C" fn read_async_trampoline<
31            Q: FnOnce(Result<(gio::InputStream, GString), glib::Error>) + 'static,
32        >(
33            _source_object: *mut glib::gobject_ffi::GObject,
34            res: *mut gio::ffi::GAsyncResult,
35            user_data: glib::ffi::gpointer,
36        ) {
37            let mut error = ptr::null_mut();
38            let mut out_mime_type = ptr::null();
39            let ret = ffi::gdk_clipboard_read_finish(
40                _source_object as *mut _,
41                res,
42                &mut out_mime_type,
43                &mut error,
44            );
45            let result = if error.is_null() {
46                Ok((from_glib_full(ret), from_glib_none(out_mime_type)))
47            } else {
48                Err(from_glib_full(error))
49            };
50            let callback: Box<glib::thread_guard::ThreadGuard<Q>> =
51                Box::from_raw(user_data as *mut _);
52            let callback = callback.into_inner();
53            callback(result);
54        }
55        let callback = read_async_trampoline::<Q>;
56        unsafe {
57            ffi::gdk_clipboard_read_async(
58                self.to_glib_none().0,
59                mime_types.to_glib_none().0,
60                io_priority.into_glib(),
61                cancellable.map(|p| p.as_ref()).to_glib_none().0,
62                Some(callback),
63                Box::into_raw(user_data) as *mut _,
64            );
65        }
66    }
67
68    #[allow(clippy::type_complexity)]
69    pub fn read_future(
70        &self,
71        mime_types: &[&str],
72        io_priority: glib::Priority,
73    ) -> Pin<
74        Box<
75            dyn future::Future<Output = Result<(gio::InputStream, GString), glib::Error>> + 'static,
76        >,
77    > {
78        let mime_types = mime_types
79            .iter()
80            .copied()
81            .map(String::from)
82            .collect::<Vec<_>>();
83        Box::pin(gio::GioFuture::new(self, move |obj, cancellable, send| {
84            let mime_types = mime_types.iter().map(|s| s.as_str()).collect::<Vec<_>>();
85            obj.read_async(&mime_types, io_priority, Some(cancellable), move |res| {
86                send.resolve(res);
87            });
88        }))
89    }
90
91    #[doc(alias = "gdk_clipboard_set")]
92    #[doc(alias = "gdk_clipboard_set_value")]
93    #[doc(alias = "gdk_clipboard_set_valist")]
94    #[doc(alias = "set_value")]
95    #[doc(alias = "set_valist")]
96    pub fn set(&self, value: &impl ToValue) {
97        unsafe {
98            ffi::gdk_clipboard_set_value(self.to_glib_none().0, value.to_value().to_glib_none().0);
99        }
100    }
101}
gdk4/clipboard.rs

gdk4/
clipboard.rs
