actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-02-20 07:40:33 +01:00
Code Issues Releases Wiki Activity

add Service combinators

Browse Source
This commit is contained in:
Nikolay Kim 2018-08-29 12:20:35 -07:00
parent 6f607e79db
commit eeb4f8c61c
1 changed files with 33 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/service/mod.rs
View File

@ -9,12 +9,39 @@ mod map_err;
mod map_init_err; mod map_init_err;
pub use self::and_then::{AndThen, AndThenNewService}; pub use self::and_then::{AndThen, AndThenNewService};
pub use self::fn_service::{FnService, FnNewService}; pub use self::fn_service::{FnNewService, FnService};
pub use self::fn_state_service::{FnStateService, FnStateNewService}; pub use self::fn_state_service::{FnStateNewService, FnStateService};
pub use self::map::{Map, MapNewService}; pub use self::map::{Map, MapNewService};
pub use self::map_err::{MapErr, MapErrNewService}; pub use self::map_err::{MapErr, MapErrNewService};
pub use self::map_init_err::MapInitErr; pub use self::map_init_err::MapInitErr;
pub trait ServiceExt: Service {
fn and_then<F, B>(self, new_service: F) -> AndThen<Self, B>
where
Self: Sized,
F: IntoService<B>,
B: Service<Request = Self::Response, Error = Self::Error>,
{
AndThen::new(self, new_service.into_service())
}
fn map<F, R>(self, f: F) -> Map<Self, F, R>
where
Self: Sized,
F: Fn(Self::Response) -> R,
{
Map::new(self, f)
}
fn map_err<F, E>(self, f: F) -> MapErr<Self, F, E>
where
Self: Sized,
F: Fn(Self::Error) -> E,
{
MapErr::new(self, f)
}
}
pub trait NewServiceExt: NewService { pub trait NewServiceExt: NewService {
fn and_then<F, B>(self, new_service: F) -> AndThenNewService<Self, B> fn and_then<F, B>(self, new_service: F) -> AndThenNewService<Self, B>
where where
@ -54,6 +81,7 @@ pub trait NewServiceExt: NewService {
} }
} }
impl<T: Service> ServiceExt for T {}
impl<T: NewService> NewServiceExt for T {} impl<T: NewService> NewServiceExt for T {}
/// Trait for types that can be converted to a Service /// Trait for types that can be converted to a Service
@ -62,7 +90,7 @@ where
T: Service, T: Service,
{ {
/// Create service /// Create service
fn into(self) -> T; fn into_service(self) -> T;
} }
/// Trait for types that can be converted to a Service /// Trait for types that can be converted to a Service
@ -78,7 +106,7 @@ impl<T> IntoService<T> for T
where where
T: Service, T: Service,
{ {
fn into(self) -> T { fn into_service(self) -> T {
self self
} }
} }
@ -97,7 +125,7 @@ where
F: Fn(Req) -> Fut + 'static, F: Fn(Req) -> Fut + 'static,
Fut: IntoFuture<Item = Resp, Error = Err>, Fut: IntoFuture<Item = Resp, Error = Err>,
{ {
fn into(self) -> FnService<F, Req, Resp, Err, Fut> { fn into_service(self) -> FnService<F, Req, Resp, Err, Fut> {
FnService::new(self) FnService::new(self)
} }
} }