pub struct Pipeline<S> { /* private fields */ }
Expand description
Container for a service.
Container allows to call enclosed service and adds support of shared readiness.
Implementations§
source§impl<S> Pipeline<S>
impl<S> Pipeline<S>
sourcepub fn poll_ready<R>(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <S as Service<R>>::Error>>where
S: Service<R>,
pub fn poll_ready<R>( &self, cx: &mut Context<'_> ) -> Poll<Result<(), <S as Service<R>>::Error>>where S: Service<R>,
Returns Ready
when the service is able to process requests.
sourcepub fn poll_shutdown<R>(&self, cx: &mut Context<'_>) -> Poll<()>where
S: Service<R>,
pub fn poll_shutdown<R>(&self, cx: &mut Context<'_>) -> Poll<()>where S: Service<R>,
Shutdown enclosed service.
sourcepub fn call<R>(&self, req: R) -> ServiceCall<'_, S, R> ⓘwhere
S: Service<R>,
pub fn call<R>(&self, req: R) -> ServiceCall<'_, S, R> ⓘwhere S: Service<R>,
Wait for service readiness and then create future object that resolves to service result.
sourcepub fn call_static<R>(&self, req: R) -> PipelineCall<S, R> ⓘwhere
S: Service<R> + 'static,
pub fn call_static<R>(&self, req: R) -> PipelineCall<S, R> ⓘwhere S: Service<R> + 'static,
Wait for service readiness and then create future object that resolves to service result.
sourcepub fn call_nowait<R>(&self, req: R) -> PipelineCall<S, R> ⓘwhere
S: Service<R> + 'static,
pub fn call_nowait<R>(&self, req: R) -> PipelineCall<S, R> ⓘwhere S: Service<R> + 'static,
Call service and create future object that resolves to service result.
Note, this call does not check service readiness.
sourcepub fn into_service(self) -> Option<S>
pub fn into_service(self) -> Option<S>
Extract service if container hadnt been cloned before.
Trait Implementations§
Auto Trait Implementations§
impl<S> !RefUnwindSafe for Pipeline<S>
impl<S> !Send for Pipeline<S>
impl<S> !Sync for Pipeline<S>
impl<S> Unpin for Pipeline<S>
impl<S> !UnwindSafe for Pipeline<S>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more