sigio 0.1.0

signal-based async io
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
41
42
43
44
45
46
47
48
49
50
51

use std::task::Waker;
use std::task::Poll;
use std::task::Context;
use std::io;
use std::pin::Pin;
use tokio::io::{ReadBuf, AsyncRead, AsyncWrite};
use crate::{File, poll_io};

impl tokio::io::AsyncRead for File {
	fn poll_read(
        self: Pin<&mut Self>,
        ctx: &mut Context<'_>,
        buf: &mut ReadBuf<'_>
    ) -> Poll<io::Result<()>> {
		let bbuf = buf.initialize_unfilled();
		poll_io(
			self.fd, ctx,
			self.raw_read(bbuf),
			|n| { buf.advance(n.try_into().unwrap()); })
	}
}

impl AsyncWrite for File {
    fn poll_write(
        self: Pin<&mut Self>,
        ctx: &mut Context<'_>,
        buf: &[u8]
    ) -> Poll<Result<usize, io::Error>> {
		poll_io(
			self.fd, ctx,
			self.raw_write(buf),
			|n| n.try_into().unwrap())
	}
    fn poll_flush(
        self: Pin<&mut Self>,
        ctx: &mut Context<'_>
    ) -> Poll<Result<(), io::Error>> {
		// raw file descriptors have no buffers
		Poll::Ready(Ok(()))
	}
    fn poll_shutdown(
        self: Pin<&mut Self>,
        ctx: &mut Context<'_>
    ) -> Poll<Result<(), io::Error>> {
		// cleanup is handled by Drop,
		// trying to handle it here would result in double close errors.
		Poll::Ready(Ok(()))
	}
}

// TODO: AsyncSeek