ed-journals 0.13.0

Provides models for representing and parsing elite dangerous journal files
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

use crate::fs::traits::unblocker::Unblocker;
use crate::fs::{BlockResult, LogFSError};
use futures::channel::mpsc::Sender;
use std::sync::{Arc, Mutex};

/// Unblocks the associated [AsyncBlocker](crate::fs::AsyncBlocker) by sending a message to the
/// associated channel.
#[derive(Clone)]
pub struct AsyncUnblocker {
    sender: Arc<Mutex<Sender<BlockResult>>>,
}

impl AsyncUnblocker {
    pub fn new(sender: Sender<BlockResult>) -> Self {
        AsyncUnblocker {
            sender: Arc::new(Mutex::new(sender)),
        }
    }
}

impl Unblocker for AsyncUnblocker {
    fn unblock(&self, result: BlockResult) -> BlockResult {
        self.sender
            .lock()
            .as_mut()
            .map_err(|_| LogFSError::FailedToUnblock)?
            .try_send(result)
            .map_err(|_| LogFSError::FailedToUnblock)?;

        Ok(())
    }
}