fn call()

in dubbo/src/triple/transport/connection.rs [83:98]


    fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future {
        let builder = self.builder.clone().http2_only(true).to_owned();
        let mut connector = Connect::new(get_connector(self.connector), builder);
        let uri = self.host.clone();
        let fut = async move {
            debug!("send base call to {}", uri);
            let mut con = connector.call(uri).await.unwrap();

            con.call(req)
                .await
                .map_err(|err| err.into())
                .map(|res| res.map(boxed))
        };

        Box::pin(fut)
    }