diff --git a/volo-thrift/src/transport/multiplex/client.rs b/volo-thrift/src/transport/multiplex/client.rs index b8620a93..b949e55e 100644 --- a/volo-thrift/src/transport/multiplex/client.rs +++ b/volo-thrift/src/transport/multiplex/client.rs @@ -158,7 +158,7 @@ where } if cx.transport.should_reuse && resp.is_ok() { if let Transport::Pooled(pooled) = transport { - pooled.reuse(); + pooled.reuse().await; } } resp diff --git a/volo-thrift/src/transport/pool/mod.rs b/volo-thrift/src/transport/pool/mod.rs index 5e49bd30..ee6af47b 100644 --- a/volo-thrift/src/transport/pool/mod.rs +++ b/volo-thrift/src/transport/pool/mod.rs @@ -424,7 +424,7 @@ impl Transport> { pub async fn reuse(self) { match self { Transport::Pooled(pooled) => { - pooled.reuse(); + pooled.reuse().await; } Transport::UnPooled(t) => { t.reuse().await;