Rft: Update Invoker Trait

dubbo/src/protocol/mod.rs

@@ -48,6 +48,8 @@ pub trait Invoker<ReqBody> {
 
     fn get_url(&self) -> Url;
 
+    fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>;
+
     fn call(&mut self, req: ReqBody) -> Self::Future;
 }
 

dubbo/src/protocol/triple/triple_invoker.rs

@@ -21,31 +21,24 @@ use tower_service::Service;
 
 use crate::common::url::Url;
 use crate::protocol::Invoker;
-use crate::triple::transport::connection::Connection;
+use crate::triple::client::builder::{ClientBoxService, ClientBuilder};
 
-#[allow(dead_code)]
-#[derive(Clone, Default)]
 pub struct TripleInvoker {
     url: Url,
-    conn: Connection,
+    conn: ClientBoxService,
 }
 
 impl TripleInvoker {
     pub fn new(url: Url) -> TripleInvoker {
         let uri = http::Uri::from_str(&url.to_url()).unwrap();
         Self {
             url,
-            conn: Connection::new().with_host(uri),
+            conn: ClientBuilder::from(uri).connect(),
         }
     }
 }
 
-impl<ReqBody> Invoker<http::Request<ReqBody>> for TripleInvoker
-where
-    ReqBody: http_body::Body + Unpin + Send + 'static,
-    ReqBody::Error: Into<crate::Error>,
-    ReqBody::Data: Send + Unpin,
-{
+impl Invoker<http::Request<hyper::Body>> for TripleInvoker {
     type Response = http::Response<crate::BoxBody>;
 
     type Error = crate::Error;
@@ -56,7 +49,14 @@ where
         self.url.clone()
     }
 
-    fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future {
+    fn call(&mut self, req: http::Request<hyper::Body>) -> Self::Future {
         self.conn.call(req)
     }
+
+    fn poll_ready(
+        &mut self,
+        cx: &mut std::task::Context<'_>,
+    ) -> std::task::Poll<Result<(), Self::Error>> {
+        self.conn.poll_ready(cx)
+    }
 }

dubbo/src/triple/client/builder.rs

@@ -88,7 +88,7 @@ impl From<Uri> for ClientBuilder {
         Self {
             uri: u,
             timeout: None,
-            connector: "",
+            connector: "tcp",
         }
     }
 }