gio/
threaded_socket_service.rs

1// Take a look at the license at the top of the repository in the LICENSE file.
2
3use glib::{prelude::*, translate::*};
4
5use crate::{SocketService, ThreadedSocketService};
6
7impl ThreadedSocketService {
8    #[doc(alias = "g_threaded_socket_service_new")]
9    pub fn new(max_threads: Option<u32>) -> ThreadedSocketService {
10        let max_threads = max_threads.map(|x| x as i32).unwrap_or(-1);
11        unsafe {
12            SocketService::from_glib_full(crate::ffi::g_threaded_socket_service_new(max_threads))
13                .unsafe_cast()
14        }
15    }
16}