fix: response future should close channel before callback

apache · Nov 28, 2023 · 4aa8c78 · 4aa8c78
1 parent 7ae83c4
commit 4aa8c78
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 {