diff --git a/internal/remote/remote_client.go b/internal/remote/remote_client.go index 7b5b1ea8..dae364e1 100644 --- a/internal/remote/remote_client.go +++ b/internal/remote/remote_client.go @@ -194,7 +194,7 @@ func (c *remotingClient) processCMD(cmd *RemotingCommand, r *tcpConnWrapper) { responseFuture.ResponseCommand = cmd responseFuture.executeInvokeCallback() if responseFuture.Done != nil { - responseFuture.Done <- true + close(responseFuture.Done) } }) }