[rocketmq-client-go] branch master updated: fix(remote_client):avoid goroutine leak

[jianhaixu]

This is an automated email from the ASF dual-hosted git repository.

jianhaixu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new 06ef9b6  fix(remote_client):avoid goroutine leak
     new 99c88b4  Merge pull request #535 from murDDock/dev
06ef9b6 is described below

commit 06ef9b6fdacc47ff73926719a9e63269e682241f
Author: huangxingning <huangxingn...@bytedance.com>
AuthorDate: Mon Sep 14 20:44:42 2020 +0800

    fix(remote_client):avoid goroutine leak
    
    Change-Id: I0b839dc76427ba2d278f3670d339e79ba2c380fb
---
 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 7b5b1ea..dae364e 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)
                                }
                        })
                }