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
28
29
30
31
32
33

use actix::prelude::*;
use mangadex_api_schema_rust::v5::CoverObject as Object;

use crate::download::{
    cover::task::{CoverDownloadTask as Task, CoverDownloadingState as State},
    messages::WaitForFinishedMessage,
    state::WaitForFinished,
    traits::task::CanBeWaited,
};

pub type WaitForFinishedCoverMessage = WaitForFinishedMessage<Object, State>;

impl CanBeWaited for Task {
    type Loading = State;
    type Ok = Object;
    fn wait(&mut self) -> WaitForFinished<Self::Ok, Self::Loading> {
        if !self.have_been_read {
            self.have_been_read = true;
        }
        WaitForFinished::new(self.sender.subscribe())
    }
}

impl Handler<WaitForFinishedCoverMessage> for Task {
    type Result = <WaitForFinishedCoverMessage as Message>::Result;
    fn handle(
        &mut self,
        _msg: WaitForFinishedCoverMessage,
        _ctx: &mut Self::Context,
    ) -> Self::Result {
        self.wait()
    }
}