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

remove debug print, remove unused flags

Browse Source
This commit is contained in:
Nikolay Kim 2019-03-11 16:47:12 -07:00
parent e15e4f18fd
commit 409888fcd5
2 changed files with 1 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/h2/dispatcher.rs
View File

@ -28,20 +28,12 @@ use crate::response::Response;
const CHUNK_SIZE: usize = 16_384; const CHUNK_SIZE: usize = 16_384;
bitflags! {
struct Flags: u8 {
const DISCONNECTED = 0b0000_0001;
const SHUTDOWN = 0b0000_0010;
}
}
/// Dispatcher for HTTP/2 protocol /// Dispatcher for HTTP/2 protocol
pub struct Dispatcher< pub struct Dispatcher<
T: AsyncRead + AsyncWrite, T: AsyncRead + AsyncWrite,
S: Service<Request = Request> + 'static, S: Service<Request = Request> + 'static,
B: MessageBody, B: MessageBody,
> { > {
flags: Flags,
service: CloneableService<S>, service: CloneableService<S>,
connection: Connection<T, Bytes>, connection: Connection<T, Bytes>,
config: ServiceConfig, config: ServiceConfig,
@ -86,7 +78,6 @@ where
ka_expire, ka_expire,
ka_timer, ka_timer,
connection, connection,
flags: Flags::empty(),
_t: PhantomData, _t: PhantomData,
} }
} }

5
src/h2/mod.rs
View File

@ -40,10 +40,7 @@ impl Stream for Payload {
} }
Ok(Async::Ready(None)) => Ok(Async::Ready(None)), Ok(Async::Ready(None)) => Ok(Async::Ready(None)),
Ok(Async::NotReady) => Ok(Async::NotReady), Ok(Async::NotReady) => Ok(Async::NotReady),
Err(err) => { Err(err) => Err(err.into()),
println!("======== {:?}", err);
Err(err.into())
}
} }
} }
} }