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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
use glib::object::IsA;
use glib::translate::*;
use gtk_source_sys;
use std::boxed::Box;
use std::ptr;
use FileLoader;
pub trait FileLoaderExtManual {
fn load_async<
P: IsA<gio::Cancellable>,
Q: 'static + Fn(i64, i64) + Send,
R: 'static + FnOnce(Result<(), glib::Error>) + Send,
>(
&self,
io_priority: glib::Priority,
cancellable: Option<&P>,
progress_callback: Q,
ready_callback: R,
);
}
impl<O: IsA<FileLoader>> FileLoaderExtManual for O {
fn load_async<
P: IsA<gio::Cancellable>,
Q: 'static + Fn(i64, i64) + Send,
R: 'static + FnOnce(Result<(), glib::Error>) + Send,
>(
&self,
io_priority: glib::Priority,
cancellable: Option<&P>,
progress_callback: Q,
ready_callback: R,
) {
unsafe extern "C" fn load_async_progress_trampoline<Q: 'static + Fn(i64, i64) + Send>(
current_num_bytes: i64,
total_num_bytes: i64,
user_data: glib_sys::gpointer,
) {
let callback = &*(user_data as *const Q);
callback(current_num_bytes, total_num_bytes);
}
unsafe extern "C" fn load_async_ready_trampoline<
R: 'static + FnOnce(Result<(), glib::Error>) + Send,
>(
source_object: *mut gobject_sys::GObject,
res: *mut gio_sys::GAsyncResult,
user_data: glib_sys::gpointer,
) {
let mut error = ptr::null_mut();
let ret = gtk_source_sys::gtk_source_file_loader_load_finish(
source_object as *mut _,
res,
&mut error,
);
let result = if !error.is_null() {
Err(from_glib_full(error))
} else if ret == glib_sys::GFALSE {
Err(glib::Error::new(
glib::FileError::Failed,
"Unexpected failure",
))
} else {
Ok(())
};
let callback = Box::from_raw(user_data as *mut R);
callback(result);
}
unsafe extern "C" fn load_async_notify_trampoline<Q: 'static + Fn(i64, i64) + Send>(
user_data: glib_sys::gpointer,
) {
Box::from_raw(user_data as *mut Q);
}
unsafe {
gtk_source_sys::gtk_source_file_loader_load_async(
self.as_ref().to_glib_none().0,
io_priority.to_glib(),
cancellable.map(|p| p.as_ref()).to_glib_none().0,
Some(load_async_progress_trampoline::<Q>),
Box::into_raw(Box::new(progress_callback)) as *mut _,
Some(load_async_notify_trampoline::<Q>),
Some(load_async_ready_trampoline::<R>),
Box::into_raw(Box::new(ready_callback)) as *mut _,
);
}
}
}