taskio 0.1.0-alpha-1

Abstractions for non-blocking tasks and 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

use super::Task;
use crate::Poll;
use core::pin::Pin;

pub fn ready<T>(value: T) -> Ready<T> {
    Ready { value: Some(value) }
}

pub struct Ready<T> {
    value: Option<T>,
}

impl<T: Unpin> Task for Ready<T> {
    type Output = T;

    fn poll(mut self: Pin<&mut Self>) -> Poll<Self::Output> {
        let value = self
            .value
            .take()
            .expect("Ready task polled after completion.");
        Poll::Ready(value)
    }
}