fix: support oneway for shmipc

cloudwego · Aug 8, 2024 · 74ccd8f · 74ccd8f
1 parent 9f9c666
commit 74ccd8f
Showing 1 changed file with 4 additions and 9 deletions.
diff --git a/volo-thrift/src/transport/pingpong/client.rs b/volo-thrift/src/transport/pingpong/client.rs
@@ -123,15 +123,10 @@ where
         let shmipc_target = rpc_info.callee().shmipc_address();
         let oneway = cx.message_type == TMessageType::OneWay;
         cx.stats.record_make_transport_start_at();
-        let mut transport = if !oneway {
-            self.make_transport
-                .call((target, shmipc_target.clone(), Ver::PingPong))
-                .await?
-        } else {
-            self.make_transport
-                .call((target, None, Ver::PingPong))
-                .await?
-        };
+        let mut transport = self
+            .make_transport
+            .call((target, shmipc_target.clone(), Ver::PingPong))
+            .await?;
         cx.stats.record_make_transport_end_at();
         let resp = transport.send(cx, req, oneway).await;
         if let Ok(None) = resp {