From 4aa8c78e4fe421ce13cea6571b3476d3251206d6 Mon Sep 17 00:00:00 2001
From: WeizhongTu <weizhong.twz@alibaba-inc.com>
Date: Tue, 28 Nov 2023 17:42:13 +0800
Subject: [PATCH] fix: response future should close channel before callback

---
 internal/remote/remote_client.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/remote/remote_client.go b/internal/remote/remote_client.go
index 36fbea7a..1f598c33 100644
--- a/internal/remote/remote_client.go
+++ b/internal/remote/remote_client.go
@@ -230,10 +230,10 @@ func (c *remotingClient) processCMD(cmd *RemotingCommand, r *tcpConnWrapper) {
 			responseFuture := resp.(*ResponseFuture)
 			go primitive.WithRecover(func() {
 				responseFuture.ResponseCommand = cmd
-				responseFuture.executeInvokeCallback()
 				if responseFuture.Done != nil {
 					close(responseFuture.Done)
 				}
+				responseFuture.executeInvokeCallback()
 			})
 		}
 	} else {