async fn send_async_inner(
        &self,
        mut request: Request<AsyncBody>,
    ) -> Result<Response<AsyncBody>, Error> {
        // Set redirect policy if not specified.
        if request.extensions().get::<RedirectPolicy>().is_none() {
            if let Some(policy) = self.inner.defaults.get::<RedirectPolicy>().cloned() {
                request.extensions_mut().insert(policy);
            }
        }

        let ctx = interceptor::Context {
            invoker: Arc::new(self),
            interceptors: &self.inner.interceptors,
        };

        ctx.send(request).await
    }
/// Actually send the request. All the public methods go through here.
Actually send the request. All the public methods go through here.
Actually send the request . All the public methods go through here .
async fn send_async_inner(
        &self,
        mut request: Request<AsyncBody>,
    ) -> Result<Response<AsyncBody>, Error> {
        // Set redirect policy if not specified.
        if request.extensions().get::<RedirectPolicy>().is_none() {
            if let Some(policy) = self.inner.defaults.get::<RedirectPolicy>().cloned() {
                request.extensions_mut().insert(policy);
            }
        }
        let ctx = interceptor::Context {
            invoker: Arc::new(self),
            interceptors: &self.inner.interceptors,
        };
        ctx.send(request).await
    }
async fn send_async_inner ( & self , mut request : Request < AsyncBody > , ) -> Result < Response < AsyncBody > , Error > { // Set redirect policy if not specified. if request . extensions ( ) . get :: < RedirectPolicy > ( ) . is_none ( ) { if let Some ( policy ) = self . inner . defaults . get :: < RedirectPolicy > ( ) . cloned ( ) { request . extensions_mut ( ) . insert ( policy ) ; } } let ctx = interceptor :: Context { invoker : Arc :: new ( self ) , interceptors : & self . inner . interceptors , } ; ctx . send ( request ) . await }
Actually send the request.
Actually send the request .
&self
request
Request<AsyncBody>
&self
request
Request<AsyncBody>