mob_push 0.2.1

notify pusher using Mob Push
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
37
38
39
40
41
42
43

mod create_push;
mod push_model;

use tokio::sync::mpsc;

use crate::{
    error::{self, MobPushError},
    http_client::PushClient,
    UserSubscribeManage,
};

/// mob push 推送器
pub struct MobPusher<M: UserSubscribeManage, C: PushClient> {
    manage: M,
    client: C,
    income_channel: mpsc::Receiver<M::PushData>,
    error_send: mpsc::Sender<error::MobPushError<M, C>>,
}

impl<M: UserSubscribeManage, C: PushClient> MobPusher<M, C> {
    pub fn new(
        client: C,
        manage: M,
        buff_size: usize,
    ) -> (
        Self,
        mpsc::Sender<M::PushData>,
        mpsc::Receiver<MobPushError<M, C>>,
    ) {
        let (rx, tx) = mpsc::channel(buff_size);
        let (err_rx, err_tx) = mpsc::channel(16);
        (
            Self {
                manage,
                income_channel: tx,
                error_send: err_rx,
                client,
            },
            rx,
            err_tx,
        )
    }
}