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()
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()
19 pub(crate) io_source: IoSource<T>, field25 .map(|io_source| TimerAsync { io_source }) in new()40 self.io_source.as_source_mut().reset(dur, interval) in reset()45 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;
57 mod io_source;
1 use crate::io_source::IoSource;
10 use crate::io_source::IoSource;
11 use crate::io_source::IoSource;