Searched refs:io_source (Results 1 – 16 of 16) sorted by relevance
18 ex.async_from(event).map(|io_source| EventAsync { in new()19 io_source, in new()27 ex.async_from(event).map(|io_source| EventAsync { in new_without_reset()28 io_source, in new_without_reset()59 self.io_source.wait_for_handle().await?; in next_val()62 self.io_source in next_val()
13 self.io_source.wait_for_handle().await in wait_sys()
19 pub(crate) io_source: IoSource<T>, field25 .map(|io_source| TimerAsync { io_source }) in new()38 self.io_source.as_source_mut().reset_oneshot(dur) in reset_oneshot()43 self.io_source.as_source_mut().reset_repeating(dur) in reset_repeating()48 self.io_source.as_source_mut().clear() in clear()
12 pub(crate) io_source: IoSource<Event>, field19 &self.io_source in get_io_source_ref()
65 mod io_source; module101 pub use io_source::IoSource;
15 .map(|io_source| EventAsync { io_source }) in new()21 .io_source in next_val()49 .map(|io_source| EventAsync { io_source }) in new_poll()57 .map(|io_source| EventAsync { io_source }) in new_uring()
15 .io_source in wait_sys()47 .map(|io_source| TimerAsync { io_source }) in new_poll()55 .map(|io_source| TimerAsync { io_source }) in new_uring()
30 pub fn new(io_source: F, ex: &Arc<RawExecutor<UringReactor>>) -> Result<UringSource<F>> { in new()31 let r = ex.reactor.register_source(ex, &io_source)?; in new()34 source: io_source, in new()
57 mod io_source;
6 use crate::io_source::IoSource;
7 use crate::io_source::IoSource;
8 use crate::io_source::IoSource;
14 use crate::io_source::IoSource;
15 use crate::io_source::IoSource;
23 use crate::io_source::IoSource;
71 use crate::io_source::IoSource;