topograph 0.4.0

A miniscule thread pool and toposort scheduler
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::{
    pin::{pin, Pin},
    task::{Context, Poll},
};

use dispose::abort_on_panic;
use futures_util::Future;
use pin_project::pin_project;

#[pin_project]
#[derive(Debug)]
#[must_use = "futures do nothing unless you `.await` or poll them"]
pub struct AbortOnPanic<F>(#[pin] pub F);

impl<F: Future> Future for AbortOnPanic<F> {
    type Output = F::Output;

    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        abort_on_panic(|| self.project().0.poll(cx))
    }
}