photonio-uring 0.0.5

A PhotonIO implementation based on io_uring.
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

//! The PhotonIO runtime.

use std::{future::Future, io::Result};

use futures::executor::block_on;

use crate::task::JoinHandle;

mod builder;
pub use builder::Builder;

mod shared;
use shared::Shared;

mod driver;

mod worker;
pub use worker::spawn;

pub(crate) mod syscall;

/// The PhotonIO runtime.
pub struct Runtime(Shared);

impl Runtime {
    /// Creates a runtime with default options.
    pub fn new() -> Result<Self> {
        Builder::new().build()
    }

    /// Runs a future to completion.
    pub fn block_on<F>(&self, future: F) -> F::Output
    where
        F: Future + Send + 'static,
        F::Output: Send + 'static,
    {
        // If the task panics, propagates the panic to the caller.
        block_on(self.spawn(future)).unwrap()
    }

    /// Spawns a future onto this runtime.
    pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>
    where
        F: Future + Send + 'static,
        F::Output: Send + 'static,
    {
        self.0.schedule(future)
    }
}