eureka-mmanager 0.1.3

An Actix actor collection for downloading manga, chapters, covers from Mangadex
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

use actix::prelude::*;

use crate::{
    history::{
        history_w_file::traits::{AsyncCommitable, Commitable},
        service::HistoryActorService,
    },
    ManagerCoreResult,
};

#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Default, Message)]
#[rtype(result = "ManagerCoreResult<()>")]
pub struct CommitMessage;

impl Handler<CommitMessage> for HistoryActorService {
    type Result = ManagerCoreResult<()>;
    fn handle(&mut self, _msg: CommitMessage, _ctx: &mut Self::Context) -> Self::Result {
        <Self as Commitable>::commit(self)
    }
}

impl AsyncCommitable for Addr<HistoryActorService> {
    type Output = ManagerCoreResult<()>;
    async fn commit(&self) -> <Self as AsyncCommitable>::Output {
        self.send(CommitMessage).await?
    }
}