Fix client RPC stream close mutex (micro#1643)

job2wd · May 18, 2020 · 3d36398 · 3d36398
1 parent 56a7897
commit 3d36398
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/client/rpc_stream.go b/client/rpc_stream.go
@@ -130,15 +130,15 @@ func (r *rpcStream) Error() error {
 }
 
 func (r *rpcStream) Close() error {
-	r.RLock()
+	r.Lock()
 
 	select {
 	case <-r.closed:
-		r.RUnlock()
+		r.Unlock()
 		return nil
 	default:
 		close(r.closed)
-		r.RUnlock()
+		r.Unlock()
 
 		// send the end of stream message
 		if r.sendEOS {