fix: response future should close channel before callback (#1113)

apache · Dec 4, 2023 · 3f9c59f · 3f9c59f
1 parent 7ffb599
commit 3f9c59f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/remote/remote_client.go b/internal/remote/remote_client.go
@@ -231,10 +231,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 {