actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2024-11-27 19:12:56 +01:00
Code Issues Releases Wiki Activity

change AndThen InitError constrain

Browse Source
This commit is contained in:
Nikolay Kim 2018-08-29 21:31:43 -07:00
parent 9b48e952b8
commit 42b0d53c16
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/service/and_then.rs
View File

@ -126,6 +126,7 @@ impl<A, B> NewService for AndThenNewService<A, B>
where
A: NewService<Response = B::Request, InitError = B::InitError>,
A::Error: Into<B::Error>,
A::InitError: Into<B::InitError>,
B: NewService,
{
type Request = A::Request;
@ -133,7 +134,7 @@ where
type Error = B::Error;
type Service = AndThen<A::Service, B::Service>;
type InitError = A::InitError;
type InitError = B::InitError;
type Future = AndThenNewServiceFuture<A, B>;
fn new_service(&self) -> Self::Future {
@ -145,6 +146,7 @@ impl<A, B> Clone for AndThenNewService<A, B>
where
A: NewService<Response = B::Request, InitError = B::InitError> + Clone,
A::Error: Into<B::Error>,
A::InitError: Into<B::InitError>,
B: NewService + Clone,
{
fn clone(&self) -> Self {
@ -185,14 +187,15 @@ impl<A, B> Future for AndThenNewServiceFuture<A, B>
where
A: NewService,
A::Error: Into<B::Error>,
B: NewService<Request = A::Response, InitError = A::InitError>,
A::InitError: Into<B::InitError>,
B: NewService<Request = A::Response>,
{
type Item = AndThen<A::Service, B::Service>;
type Error = B::InitError;
fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
if self.a.is_none() {
if let Async::Ready(service) = self.fut_a.poll()? {
if let Async::Ready(service) = self.fut_a.poll().map_err(|e| e.into())? {
self.a = Some(service);
}
}