Struct ntex_service::Pipeline [−][src]
pub struct Pipeline<T> { /* fields omitted */ }
Expand description
Pipeline service - pipeline allows to compose multiple service into one service.
Implementations
impl<T: Service> Pipeline<T>
[src]
impl<T: Service> Pipeline<T>
[src]pub fn and_then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = T::Request, Response = U::Response, Error = T::Error> + Clone> where
Self: Sized,
F: IntoService<U>,
U: Service<Request = T::Response, Error = T::Error>,
[src]
pub fn and_then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = T::Request, Response = U::Response, Error = T::Error> + Clone> where
Self: Sized,
F: IntoService<U>,
U: Service<Request = T::Response, Error = T::Error>,
[src]Call another service after call to this one has resolved successfully.
This function can be used to chain two services together and ensure that the second service isn’t called until call to the fist service have finished. Result of the call to the first service is used as an input parameter for the second service’s call.
Note that this function consumes the receiving service and returns a wrapped version of it.
pub fn and_then_apply_fn<U, I, F, Fut, Res, Err>(
self,
service: I,
f: F
) -> Pipeline<impl Service<Request = T::Request, Response = Res, Error = Err> + Clone> where
Self: Sized,
I: IntoService<U>,
U: Service,
F: Fn(T::Response, &U) -> Fut,
Fut: Future<Output = Result<Res, Err>>,
Err: From<T::Error> + From<U::Error>,
[src]
pub fn and_then_apply_fn<U, I, F, Fut, Res, Err>(
self,
service: I,
f: F
) -> Pipeline<impl Service<Request = T::Request, Response = Res, Error = Err> + Clone> where
Self: Sized,
I: IntoService<U>,
U: Service,
F: Fn(T::Response, &U) -> Fut,
Fut: Future<Output = Result<Res, Err>>,
Err: From<T::Error> + From<U::Error>,
[src]Apply function to specified service and use it as a next service in chain.
Short version of pipeline_factory(...).and_then(apply_fn_factory(...))
pub fn then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = T::Request, Response = U::Response, Error = T::Error> + Clone> where
Self: Sized,
F: IntoService<U>,
U: Service<Request = Result<T::Response, T::Error>, Error = T::Error>,
[src]
pub fn then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = T::Request, Response = U::Response, Error = T::Error> + Clone> where
Self: Sized,
F: IntoService<U>,
U: Service<Request = Result<T::Response, T::Error>, Error = T::Error>,
[src]Chain on a computation for when a call to the service finished,
passing the result of the call to the next service U
.
Note that this function consumes the receiving pipeline and returns a wrapped version of it.
pub fn map<F, R>(self, f: F) -> Pipeline<Map<T, F, R>> where
Self: Sized,
F: FnMut(T::Response) -> R,
[src]
pub fn map<F, R>(self, f: F) -> Pipeline<Map<T, F, R>> where
Self: Sized,
F: FnMut(T::Response) -> R,
[src]Map this service’s output to a different type, returning a new service of the resulting type.
This function is similar to the Option::map
or Iterator::map
where
it will change the type of the underlying service.
Note that this function consumes the receiving service and returns a
wrapped version of it, similar to the existing map
methods in the
standard library.
pub fn map_err<F, E>(self, f: F) -> Pipeline<MapErr<T, F, E>> where
Self: Sized,
F: Fn(T::Error) -> E,
[src]
pub fn map_err<F, E>(self, f: F) -> Pipeline<MapErr<T, F, E>> where
Self: Sized,
F: Fn(T::Error) -> E,
[src]Map this service’s error to a different error, returning a new service.
This function is similar to the Result::map_err
where it will change
the error type of the underlying service. This is useful for example to
ensure that services have the same error type.
Note that this function consumes the receiving service and returns a wrapped version of it.
Trait Implementations
impl<T: Service> Service for Pipeline<T>
[src]
impl<T: Service> Service for Pipeline<T>
[src]fn poll_ready(&self, cx: &mut Context<'_>) -> Poll<Result<(), T::Error>>
[src]
fn poll_ready(&self, cx: &mut Context<'_>) -> Poll<Result<(), T::Error>>
[src]Returns Ready
when the service is able to process requests. Read more
fn poll_shutdown(&self, cx: &mut Context<'_>, is_error: bool) -> Poll<()>
[src]
fn poll_shutdown(&self, cx: &mut Context<'_>, is_error: bool) -> Poll<()>
[src]Shutdown service. Read more
fn call(&self, req: T::Request) -> Self::Future
[src]
fn call(&self, req: T::Request) -> Self::Future
[src]Process the request and return the response asynchronously. Read more
Auto Trait Implementations
impl<T> RefUnwindSafe for Pipeline<T> where
T: RefUnwindSafe,
T: RefUnwindSafe,
impl<T> Send for Pipeline<T> where
T: Send,
T: Send,
impl<T> Sync for Pipeline<T> where
T: Sync,
T: Sync,
impl<T> Unpin for Pipeline<T> where
T: Unpin,
T: Unpin,
impl<T> UnwindSafe for Pipeline<T> where
T: UnwindSafe,
T: UnwindSafe,
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> IntoService<T> for T where
T: Service,
[src]
impl<T> IntoService<T> for T where
T: Service,
[src]pub fn into_service(Self) -> T
[src]
pub fn into_service(Self) -> T
[src]Convert to a Service
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more