neptune-job-queue 0.14.2

Prioritized, heterogeneous async/blocking job queue used by neptune-cash
Documentation 
1
2
3
4
5
6
7
8
9
10

use tokio::sync::oneshot;
use tokio::sync::watch;

use super::job_completion::JobCompletion;

pub type JobCancelReceiver = watch::Receiver<()>; // used in pub trait
pub(super) type JobCancelSender = watch::Sender<()>;

pub(super) type JobResultReceiver = oneshot::Receiver<JobCompletion>;
pub(super) type JobResultSender = oneshot::Sender<JobCompletion>;