rust_asio 0.6.0

Asynchronous I/O library
Documentation 
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

use super::{Dispatcher, IntrFdImpl, AsyncFdImpl};
use core::{Scheduler, Interrupter, WorkerQueue};

use std::io;
use std::sync::Arc;
use std::sync::atomic::AtomicUsize;

type Dispatch = fn();
pub type IntrFd = IntrFdImpl<Dispatch>;
pub type AsyncFd = AsyncFdImpl<Dispatch>;
pub type Reactor = NullReactor;

pub struct NullReactor;

impl NullReactor {
    pub fn new() -> io::Result<Self> {
        Ok(NullReactor)
    }

    pub fn run(&self, schd: &Scheduler, _block: bool, wq: &mut WorkerQueue) -> bool {
        schd.get_ready_timers(wq);
        false
    }

    pub fn cancel_all_fds(&self, _wq: &mut WorkerQueue) {
    }
}

impl Dispatcher for Interrupter {
    type Dispatch = Dispatch;

    fn dispatcher() -> Self::Dispatch {
        Self::dispatch
    }
}

impl Interrupter {
    fn dispatch() {
    }
}