Update mod.rs
+ added custom debug message - removed debug derive
This commit is contained in:
parent
e6d087b4d8
commit
85f02e553a
|
|
@ -1,6 +1,7 @@
|
|||
use std::sync::Arc;
|
||||
use std::io::Write;
|
||||
use std::io::Error;
|
||||
use std::fmt::Debug;
|
||||
|
||||
use async_trait::async_trait;
|
||||
use serde::Serialize;
|
||||
|
|
@ -16,7 +17,7 @@ use tokio::io::AsyncBufReadExt;
|
|||
|
||||
use crate::prelude::StreamMessageSender;
|
||||
|
||||
#[derive(Debug)]
|
||||
|
||||
pub struct SocketSender {
|
||||
stream_tx: Mutex<WriteHalf<tokio::net::TcpStream>>,
|
||||
stream_rx: Mutex<BufReader<ReadHalf<tokio::net::TcpStream>>>,
|
||||
|
|
@ -59,4 +60,12 @@ impl StreamMessageSender for SocketSender {
|
|||
|
||||
Ok(message)
|
||||
}
|
||||
}
|
||||
|
||||
impl Debug for SocketSender {
|
||||
|
||||
fn fmt(&self, f: &mut std::fmt::Formatter<'_>)
|
||||
-> std::result::Result<(), std::fmt::Error> {
|
||||
write!(f, "[SocketSender]")
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue