dofus-framework 0.1.16

This crate contains modules and functions that help sustain a dofus emulator binary application
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
44
45
46
47
48
49
50
51
52

use crate::io::tcp::client_handler::TcpClientTaskHandle;
use crate::io::tcp::tcp_client_action::TcpClientAction::{Connect, Disconnect, SendData};
use tokio::sync::mpsc;
use tokio::sync::mpsc::error::TrySendError;

#[derive(Debug)]
pub enum TcpClientAction {
    Connect {
        handle: TcpClientTaskHandle,
    },
    Disconnect {
        handle: TcpClientTaskHandle,
    },
    SendData {
        handle: TcpClientTaskHandle,
        data: String,
    },
}

pub type TcpClientActionSender = mpsc::Sender<TcpClientAction>;
pub type TcpClientActionReceiver = mpsc::Receiver<TcpClientAction>;

pub struct TcpClientActionHandle {
    sender: TcpClientActionSender,
    client_task_handle: TcpClientTaskHandle,
}

impl TcpClientActionHandle {
    pub fn new(sender: TcpClientActionSender, client_task_handle: TcpClientTaskHandle) -> Self {
        TcpClientActionHandle {
            sender,
            client_task_handle,
        }
    }

    pub fn client_disconnect(self) -> Result<(), TrySendError<TcpClientAction>> {
        self.sender.try_send(Disconnect {
            handle: self.client_task_handle,
        })
    }
    pub fn client_connect(self) -> Result<(), TrySendError<TcpClientAction>> {
        self.sender.try_send(Connect {
            handle: self.client_task_handle,
        })
    }
    pub fn client_data(self, data: String) -> Result<(), TrySendError<TcpClientAction>> {
        self.sender.try_send(SendData {
            handle: self.client_task_handle,
            data,
        })
    }
}