1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use futures::channel::oneshot;

///
/// The queue resumer is used to resume a queue that was suspended using the `suspend()` function in the scheduler
///
pub struct QueueResumer {
    pub (super) resume: oneshot::Sender<()>
}

impl QueueResumer {
    ///
    /// Resumes a suspended queue
    ///
    pub fn resume(self) {
        // Send to the channel
        self.resume.send(()).ok();
    }
}