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

remove debug prints

Browse Source
This commit is contained in:
Nikolay Kim 2018-01-03 09:00:22 -08:00
parent 70ea43b3c0
commit 88031b7fde
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/pipeline.rs
View File

@ -600,7 +600,6 @@ impl<S, H> ProcessResponse<S, H> {
Ok(Async::Ready(Some(frame))) => { Ok(Async::Ready(Some(frame))) => {
match frame { match frame {
Frame::Payload(None) => { Frame::Payload(None) => {
println!("ACTOR PAYLOAD EOF");
info.context = Some(ctx); info.context = Some(ctx);
self.iostate = IOState::Done; self.iostate = IOState::Done;
if let Err(err) = io.write_eof() { if let Err(err) = io.write_eof() {
@ -611,7 +610,6 @@ impl<S, H> ProcessResponse<S, H> {
break break
}, },
Frame::Payload(Some(chunk)) => { Frame::Payload(Some(chunk)) => {
println!("ACTOR PAYLOAD");
self.iostate = IOState::Actor(ctx); self.iostate = IOState::Actor(ctx);
match io.write(chunk.as_ref()) { match io.write(chunk.as_ref()) {
Err(err) => { Err(err) => {
@ -623,7 +621,6 @@ impl<S, H> ProcessResponse<S, H> {
} }
}, },
Frame::Drain(fut) => { Frame::Drain(fut) => {
println!("ACTOR DRAIN");
self.drain = Some(fut); self.drain = Some(fut);
self.iostate = IOState::Actor(ctx); self.iostate = IOState::Actor(ctx);
break break