actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-02-20 07:40:33 +01:00
Code Issues Releases Wiki Activity

simplify framed transport error

Browse Source
This commit is contained in:
Nikolay Kim 2018-09-24 20:51:53 -07:00
parent d4b772d454
commit 205079adce
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/framed.rs
View File

@ -159,10 +159,10 @@ where
}
/// Framed transport errors
pub enum FramedTransportError<S: Service, U: Encoder + Decoder> {
Decoder(<U as Decoder>::Error),
Encoder(<U as Encoder>::Error),
Service(S::Error),
pub enum FramedTransportError<E1, E2, E3> {
Service(E1),
Encoder(E2),
Decoder(E3),
}
/// FramedTransport - is a future that reads frames from Framed object
@ -185,8 +185,8 @@ where
enum TransportState<S: Service, U: Encoder + Decoder> {
Processing,
Error(FramedTransportError<S, U>),
EncoderError(FramedTransportError<S, U>),
Error(FramedTransportError<S::Error, <U as Encoder>::Error, <U as Decoder>::Error>),
EncoderError(FramedTransportError<S::Error, <U as Encoder>::Error, <U as Decoder>::Error>),
Stopping,
}
@ -355,7 +355,7 @@ where
<U as Encoder>::Error: 'static,
{
type Item = ();
type Error = FramedTransportError<S, U>;
type Error = FramedTransportError<S::Error, <U as Encoder>::Error, <U as Decoder>::Error>;
fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
match mem::replace(&mut self.state, TransportState::Processing) {