eureka-mmanager 0.4.0

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
34
35
36

use std::ops::Deref;

use actix::prelude::*;

use crate::{
    download::{
        chapter::task::{ChapterDownloadTask as Task, ChapterDownloadTaskState as State},
        messages::SubcribeMessage,
        traits::task::Subscribe,
    },
    recipients::MaybeWeakRecipient,
};

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

impl Subscribe for Task {
    fn subscribe(
        &mut self,
        subscriber: MaybeWeakRecipient<
            crate::download::messages::TaskSubscriberMessages<Self::State>,
        >,
    ) {
        subscriber.do_send(crate::download::messages::TaskSubscriberMessages::ID(
            self.id,
        ));
        subscriber.do_send(crate::download::messages::TaskSubscriberMessages::State(
            self.state.read().deref().clone(),
        ));
        self.subscribers.push_recipient(subscriber);
    }
}