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> Pipeline<T> where
T: Service,
[src]
impl<T> Pipeline<T> where
T: Service,
[src]pub fn and_then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = <T as Service>::Request, Response = <U as Service>::Response, Error = <T as Service>::Error> + Clone> where
U: Service<Request = <T as Service>::Response, Error = <T as Service>::Error>,
F: IntoService<U>,
Pipeline<T>: Sized,
[src]
pub fn and_then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = <T as Service>::Request, Response = <U as Service>::Response, Error = <T as Service>::Error> + Clone> where
U: Service<Request = <T as Service>::Response, Error = <T as Service>::Error>,
F: IntoService<U>,
Pipeline<T>: Sized,
[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 as Service>::Request, Response = Res, Error = Err> + Clone> where
Err: From<<T as Service>::Error> + From<<U as Service>::Error>,
U: Service,
I: IntoService<U>,
F: Fn(<T as Service>::Response, &U) -> Fut,
Fut: Future<Output = Result<Res, Err>>,
Pipeline<T>: Sized,
[src]
pub fn and_then_apply_fn<U, I, F, Fut, Res, Err>(
self,
service: I,
f: F
) -> Pipeline<impl Service<Request = <T as Service>::Request, Response = Res, Error = Err> + Clone> where
Err: From<<T as Service>::Error> + From<<U as Service>::Error>,
U: Service,
I: IntoService<U>,
F: Fn(<T as Service>::Response, &U) -> Fut,
Fut: Future<Output = Result<Res, Err>>,
Pipeline<T>: Sized,
[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 as Service>::Request, Response = <U as Service>::Response, Error = <T as Service>::Error> + Clone> where
U: Service<Request = Result<<T as Service>::Response, <T as Service>::Error>, Error = <T as Service>::Error>,
F: IntoService<U>,
Pipeline<T>: Sized,
[src]
pub fn then<F, U>(
self,
service: F
) -> Pipeline<impl Service<Request = <T as Service>::Request, Response = <U as Service>::Response, Error = <T as Service>::Error> + Clone> where
U: Service<Request = Result<<T as Service>::Response, <T as Service>::Error>, Error = <T as Service>::Error>,
F: IntoService<U>,
Pipeline<T>: Sized,
[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
F: FnMut(<T as Service>::Response) -> R,
Pipeline<T>: Sized,
[src]
pub fn map<F, R>(self, f: F) -> Pipeline<Map<T, F, R>> where
F: FnMut(<T as Service>::Response) -> R,
Pipeline<T>: Sized,
[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
F: Fn(<T as Service>::Error) -> E,
Pipeline<T>: Sized,
[src]
pub fn map_err<F, E>(self, f: F) -> Pipeline<MapErr<T, F, E>> where
F: Fn(<T as Service>::Error) -> E,
Pipeline<T>: Sized,
[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 for Pipeline<T> where
T: Service,
[src]
impl<T> Service for Pipeline<T> where
T: Service,
[src]pub fn poll_ready(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <T as Service>::Error>>
[src]
pub fn poll_ready(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <T as Service>::Error>>
[src]Returns Ready
when the service is able to process requests. Read more
pub fn poll_shutdown(&self, cx: &mut Context<'_>, is_error: bool) -> Poll<()>
[src]
pub fn poll_shutdown(&self, cx: &mut Context<'_>, is_error: bool) -> Poll<()>
[src]Shutdown service. Read more
pub fn call(
&self,
req: <T as Service>::Request
) -> <Pipeline<T> as Service>::Future
[src]
pub fn call(
&self,
req: <T as Service>::Request
) -> <Pipeline<T> as Service>::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> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]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> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
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