actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2024-11-24 01:11:07 +01:00
Code Issues Releases Wiki Activity

fix io handling code

Browse Source
This commit is contained in:
Nikolay Kim 2018-12-21 13:00:26 -08:00
parent 37d28304c9
commit 48a1c7320c
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
actix-utils/src/framed.rs
View File

@ -187,7 +187,7 @@ where
enum TransportState<S: Service<Request<U>>, U: Encoder + Decoder> {
Processing,
Error(FramedTransportError<S::Error, U>),
EncoderError(FramedTransportError<S::Error, U>),
FramedError(FramedTransportError<S::Error, U>),
Stopping,
}
@ -263,7 +263,7 @@ where
Ok(Async::Ready(Some(el))) => el,
Err(err) => {
self.state =
TransportState::Error(FramedTransportError::Decoder(err));
TransportState::FramedError(FramedTransportError::Decoder(err));
return true;
}
Ok(Async::NotReady) => return false,
@ -310,7 +310,7 @@ where
Ok(Async::Ready(Some(msg))) => match msg {
Ok(msg) => {
if let Err(err) = self.framed.force_send(msg) {
self.state = TransportState::EncoderError(
self.state = TransportState::FramedError(
FramedTransportError::Encoder(err),
);
return true;
@ -334,7 +334,7 @@ where
Err(err) => {
debug!("Error sending data: {:?}", err);
self.state =
TransportState::EncoderError(FramedTransportError::Encoder(err));
TransportState::FramedError(FramedTransportError::Encoder(err));
return true;
}
Ok(Async::Ready(_)) => (),
@ -378,7 +378,7 @@ where
Ok(Async::NotReady)
}
}
TransportState::EncoderError(err) => Err(err),
TransportState::FramedError(err) => Err(err),
TransportState::Stopping => Ok(Async::Ready(())),
}
}