mirror of
https://github.com/actix/actix-web.git
synced 2024-11-18 07:35:36 +00:00
fmt
This commit is contained in:
parent
00ba8d5549
commit
85753130d9
2 changed files with 6 additions and 10 deletions
|
@ -291,15 +291,11 @@ where
|
|||
type Future = H2ServiceHandlerResponse<T, S, B>;
|
||||
|
||||
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
|
||||
self.flow
|
||||
.borrow_mut()
|
||||
.service
|
||||
.poll_ready(cx)
|
||||
.map_err(|e| {
|
||||
let e = e.into();
|
||||
error!("Service readiness error: {:?}", e);
|
||||
DispatchError::Service(e)
|
||||
})
|
||||
self.flow.borrow_mut().service.poll_ready(cx).map_err(|e| {
|
||||
let e = e.into();
|
||||
error!("Service readiness error: {:?}", e);
|
||||
DispatchError::Service(e)
|
||||
})
|
||||
}
|
||||
|
||||
fn call(&mut self, (io, addr): (T, Option<net::SocketAddr>)) -> Self::Future {
|
||||
|
|
|
@ -581,7 +581,7 @@ where
|
|||
)),
|
||||
},
|
||||
|
||||
proto => unimplemented!("Unsupported HTTP version: {:?}.", proto)
|
||||
proto => unimplemented!("Unsupported HTTP version: {:?}.", proto),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue