Struct dofus_framework::io::tcp::client_handler::TcpClientTaskHandle

pub struct TcpClientTaskHandle { /* private fields */ }

Implementations

impl TcpClientTaskHandle

pub fn new(sender: Sender<TcpClientTaskMessage>) -> Self

Examples found in repository

src/io/tcp/client_handler.rs (line 74)

    pub fn handle_client(
        mut client_stream: TcpStream,
        tcp_client_action_sender: TcpClientActionSender,
    ) -> JoinHandle<Result<(), TcpClientTaskError>> {
        let (tcp_client_task_sender, tcp_client_task_receiver) = mpsc::channel(BUFFER_SIZE);
        tokio::spawn(async move {
            let (reader, writer) = client_stream.split();
            select! {
                res = Self::listen_to_messages(tcp_client_task_receiver, writer) => {res}
                res = Self::listen_to_client(reader, tcp_client_action_sender, TcpClientTaskHandle::new(tcp_client_task_sender)) => {res}
            }
        })
    }

pub fn send_data(
    &self,
    data: String
) -> Result<(), TrySendError<TcpClientTaskMessage>>

pub fn stop(&self) -> Result<(), TrySendError<TcpClientTaskMessage>>

Trait Implementations

impl Clone for TcpClientTaskHandle

fn clone(&self) -> TcpClientTaskHandle

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TcpClientTaskHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.