Struct ThenSvc

pub struct ThenSvc<S1, S2, Int, Res> { /* private fields */ }

Service1(Response) -> Intermediate => Service2(Intermediate) -> Response

Implementations

impl<S1, S2, Int, Res> ThenSvc<S1, S2, Int, Res>

pub fn new(svc1: S1, svc2: S2) -> Self

Trait Implementations

impl<S1, S2, Req, Int, Res> Svc<Req> for ThenSvc<S1, S2, Int, Res>

where S1: Svc<Req, Res = Int>, S2: Svc<Int, Res = Res>,

type Res = Res

Output type.

type Fut = ThenSvcFut<S1, S2, Req, Int, Res>

Response future.

fn exec(self: Pin<&mut Self>, req: Req) -> Self::Fut

Processes request, producing a future that outputs the response type.

fn poll_ready(self: Pin<&mut Self>, cx: Context<'_>) -> Poll<()>

To be called before exec to signal wether the service is ready to process requests. As such, the check should be inexpensive. Returning Poll::Pending acts as back-pressure. The default implementation unconditionally indicates the service is ready.

impl<'pin, S1, S2, Int, Res> Unpin for ThenSvc<S1, S2, Int, Res>

where PinnedFieldsOf<__ThenSvc<'pin, S1, S2, Int, Res>>: Unpin,