actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-03-11 20:12:58 +01:00
Code Issues Releases Wiki Activity

properly check readiness inclosed service

Browse Source
This commit is contained in:
Nikolay Kim 2019-01-14 09:41:10 -08:00
parent 0bee4db270
commit db2367b26e
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
actix-utils/src/stream.rs
View File

@ -160,8 +160,8 @@ where
} }
loop { loop {
if let Async::Ready(_) = self.service.poll_ready()? { match self.service.poll_ready()? {
match self.stream.poll() { Async::Ready(_) => match self.stream.poll() {
Ok(Async::Ready(Some(item))) => spawn(StreamDispatcherService { Ok(Async::Ready(Some(item))) => spawn(StreamDispatcherService {
fut: self.service.call(Ok(item)), fut: self.service.call(Ok(item)),
stop: self.err_tx.clone(), stop: self.err_tx.clone(),
@ -172,7 +172,8 @@ where
}), }),
Ok(Async::NotReady) => return Ok(Async::NotReady), Ok(Async::NotReady) => return Ok(Async::NotReady),
Ok(Async::Ready(None)) => return Ok(Async::Ready(())), Ok(Async::Ready(None)) => return Ok(Async::Ready(())),
} },
Async::NotReady => return Ok(Async::NotReady),
} }
} }
} }