We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7a06ea commit 872eac1Copy full SHA for 872eac1
src/wr/src/select/thread.rs
@@ -1,12 +1,11 @@
1
use std::ptr;
2
3
-use futures::Future;
4
use libc::pselect;
5
use lisp_types::bindings::thread_select;
6
7
use crate::event_loop::{FdSet, Timespec};
8
9
-async fn async_thread_select(
+pub async fn tokio_select_fds(
10
nfds: i32,
11
readfds: &FdSet,
12
writefds: &FdSet,
@@ -24,15 +23,3 @@ async fn async_thread_select(
24
23
)
25
}
26
27
-
28
-pub fn tokio_select_fds<'a>(
29
- nfds: i32,
30
- readfds: &'a FdSet,
31
- writefds: &'a FdSet,
32
- timeout: &'a Timespec,
33
-) -> impl Future<Output = i32> + 'a {
34
- async move {
35
- let nfds: i32 = async_thread_select(nfds, readfds, writefds, timeout).await;
36
- nfds
37
- }
38
-}
0 commit comments