Trying to acknowledge error
modified: src/client.rs
This commit is contained in:
parent
b9f141472a
commit
360256ab03
@ -52,7 +52,7 @@ pub mod general {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub trait WriteWrapper {
|
pub trait WriteWrapper {
|
||||||
async fn write(&mut self, msg: WriterMessage) -> Result<usize, ()>;
|
async fn write(&mut self, msg: WriterMessage) -> Result<usize, String>;
|
||||||
}
|
}
|
||||||
|
|
||||||
pub enum WriterMessage {
|
pub enum WriterMessage {
|
||||||
@ -66,14 +66,18 @@ pub mod general {
|
|||||||
|
|
||||||
// TODO: implement custom Error
|
// TODO: implement custom Error
|
||||||
impl WriteWrapper for DevWriter {
|
impl WriteWrapper for DevWriter {
|
||||||
async fn write(&mut self, msg: WriterMessage) -> Result<usize, ()> {
|
async fn write(&mut self, msg: WriterMessage) -> Result<usize, String> {
|
||||||
match msg {
|
match msg {
|
||||||
WriterMessage::Plain(buf) => {
|
WriterMessage::Plain(buf) => {
|
||||||
let l = buf.len();
|
let l = buf.len();
|
||||||
if let Ok(()) = self.dr.send(buf).await {
|
return match self.dr.send(buf).await {
|
||||||
|
Ok(()) => Ok(l),
|
||||||
|
Err(e) => Err(e.to_string())
|
||||||
|
};
|
||||||
|
/* if let Ok(()) = self.dr.send(buf).await {
|
||||||
return Ok(l);
|
return Ok(l);
|
||||||
}
|
}
|
||||||
Err(())
|
Err(()) */
|
||||||
},
|
},
|
||||||
// this thing should be abolished later
|
// this thing should be abolished later
|
||||||
WriterMessage::Gateway(_addr) => {
|
WriterMessage::Gateway(_addr) => {
|
||||||
@ -88,13 +92,13 @@ pub mod general {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl WriteWrapper for FdWriter {
|
impl WriteWrapper for FdWriter {
|
||||||
async fn write(&mut self, msg: WriterMessage) -> Result<usize, ()> {
|
async fn write(&mut self, msg: WriterMessage) -> Result<usize, String> {
|
||||||
match msg {
|
match msg {
|
||||||
WriterMessage::Plain(buf) => {
|
WriterMessage::Plain(buf) => {
|
||||||
if let Ok(a) = self.br.write(&buf).await {
|
if let Ok(a) = self.br.write(&buf).await {
|
||||||
return Ok(a);
|
return Ok(a);
|
||||||
}
|
}
|
||||||
Err(())
|
Err(String::new())
|
||||||
},
|
},
|
||||||
WriterMessage::Gateway(_addr) => {Ok(0)}
|
WriterMessage::Gateway(_addr) => {Ok(0)}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user