mirror of https://github.com/fafhrd91/actix-web
simplify branch
This commit is contained in:
parent
b5af52f487
commit
cadee72fe0
|
@ -150,17 +150,18 @@ where
|
||||||
loop {
|
loop {
|
||||||
match self.as_mut().project() {
|
match self.as_mut().project() {
|
||||||
HandlerProj::Extract(fut, req, handle) => {
|
HandlerProj::Extract(fut, req, handle) => {
|
||||||
let item = match ready!(fut.poll(cx)) {
|
match ready!(fut.poll(cx)) {
|
||||||
Ok(item) => item,
|
Ok(item) => {
|
||||||
|
let fut = handle.call(item);
|
||||||
|
let state = HandlerServiceFuture::Handle(fut, req.take());
|
||||||
|
self.as_mut().set(state);
|
||||||
|
}
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
let res: Response = e.into().into();
|
let res: Response = e.into().into();
|
||||||
let req = req.take().unwrap();
|
let req = req.take().unwrap();
|
||||||
return Poll::Ready(Ok(ServiceResponse::new(req, res)));
|
return Poll::Ready(Ok(ServiceResponse::new(req, res)));
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
let fut = handle.call(item);
|
|
||||||
let state = HandlerServiceFuture::Handle(fut, req.take());
|
|
||||||
self.as_mut().set(state);
|
|
||||||
}
|
}
|
||||||
HandlerProj::Handle(fut, req) => {
|
HandlerProj::Handle(fut, req) => {
|
||||||
let res = ready!(fut.poll(cx));
|
let res = ready!(fut.poll(cx));
|
||||||
|
|
Loading…
Reference in New Issue