euphony 0.1.1

music composition environment for programmers
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

use crate::{
    ext::{DelayExt, SpawnExt},
    time::Timer,
};
use bach::executor::JoinHandle;
use core::{
    future::Future,
    pin::Pin,
    task::{Context, Poll},
};

pub fn section<T: DelayExt>(time: T) -> Section {
    Section::new(time.delay())
}

pub struct Section {
    handles: Vec<JoinHandle<()>>,
    timer: Timer,
}

impl Section {
    pub fn new(timer: Timer) -> Self {
        Self {
            handles: vec![],
            timer,
        }
    }

    pub fn with<T: 'static + Future<Output = ()> + Send>(&mut self, task: T) -> &mut Self {
        self.handles.push(task.spawn());
        self
    }
}

impl Future for Section {
    type Output = ();

    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        let res = Pin::new(&mut self.timer).poll(cx);
        if res.is_ready() {
            for handle in self.handles.drain(..) {
                handle.cancel();
            }
        }
        res
    }
}