pacifica-rs 1.0.0

rust implementation of PacificA: Replication in Log-Based Distributed Storage Systems
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

use crate::error::{PacificaError};
use crate::runtime::MpscUnboundedSender;
use crate::type_config::alias::MpscUnboundedSenderOf;
use crate::TypeConfig;

pub(crate) struct TaskSender<C, T>
where
    C: TypeConfig,
    T: Send
{
    pub tx_task: MpscUnboundedSenderOf<C, T>,
}

impl<C, T> TaskSender<C, T>
where
    C: TypeConfig,
    T: Send
{

    pub(crate) fn new(tx_task: MpscUnboundedSenderOf<C, T>) -> Self {
        Self { tx_task }
    }
    pub(crate) fn send(&self, task: T) -> Result<(), PacificaError<C>> {
        self.tx_task.send(task).map_err(|_| PacificaError::Shutdown)?;
        Ok(())
    }
}