Merge pull request #7 from AliasYermukanov/master

changed from mytex to rwmytes
djumanoff · Aug 29, 2019 · 5a74442 · 5a74442
2 parents 858a109 + 1464c5b
commit 5a74442
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/client.go b/client.go
@@ -38,7 +38,7 @@ type (
 
 		responseQ string
 
-		rpcChannelsMu sync.Mutex
+		rpcChannelsMu sync.RWMutex
 		rpcChannels map[string]chan Message
 
 		close chan bool
@@ -87,9 +87,11 @@ func (clt *client) run() error {
 		for {
 			select {
 			case d := <-msgs:
+				clt.rpcChannelsMu.RLock()
 				if c, ok := clt.rpcChannels[d.CorrelationId]; ok {
 					c <- deliveryToMessage(d)
 				}
+				clt.rpcChannelsMu.RUnlock()
 			case <-clt.close:
 				fmt.Println("cleanup here?")
 				clt.cleanup()