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 {