fn route_p2c(&mut self, req: Request) -> <Self as tower::Service<Request>>::Future {
        let preselected_key = self
            .preselected_p2c_peer
            .expect("ready peer service must have a preselected peer");

        tracing::trace!(?preselected_key, "routing based on p2c");

        let mut svc = self
            .take_ready_service(&preselected_key)
            .expect("ready peer set must have preselected a ready peer");

        let fut = svc.call(req);
        self.push_unready(preselected_key, svc);
        fut.map_err(Into::into).boxed()
    }
/// Routes a request using P2C load-balancing.
Routes a request using P2C load-balancing.
Routes a request using P2C load - balancing .
fn route_p2c(&mut self, req: Request) -> <Self as tower::Service<Request>>::Future {
        let preselected_key = self
            .preselected_p2c_peer
            .expect("ready peer service must have a preselected peer");
        tracing::trace!(?preselected_key, "routing based on p2c");
        let mut svc = self
            .take_ready_service(&preselected_key)
            .expect("ready peer set must have preselected a ready peer");
        let fut = svc.call(req);
        self.push_unready(preselected_key, svc);
        fut.map_err(Into::into).boxed()
    }
fn route_p2c ( & mut self , req : Request ) -> < Self as tower :: Service < Request > > :: Future { let preselected_key = self . preselected_p2c_peer . expect ( " " ) ; tracing :: trace ! ( preselected_key " " ) ; let mut svc = self . take_ready_service ( & preselected_key ) . expect ( " " ) ; let fut = svc . call ( req ) ; self . push_unready ( preselected_key , svc ) ; fut . map_err ( Into :: into ) . boxed ( ) }
Routes a request using P2C load-balancing.
Routes a request using P2C load - balancing .
&mut self
req
Request