remove redundant select {}

Nisoka · Jan 29, 2019 · b7fc4de · b7fc4de
1 parent 0cfd775
commit b7fc4de
Showing 1 changed file with 12 additions and 13 deletions.
diff --git a/server/cluster.go b/server/cluster.go
@@ -218,22 +218,21 @@ func (n *ClusterNode) callAsync(proc string, msg, resp interface{}, done chan *r
 
 	myDone := make(chan *rpc.Call, 1)
 	go func() {
-		select {
-		case call := <-myDone:
-			if call.Error != nil {
-				n.lock.Lock()
-				if n.connected {
-					n.endpoint.Close()
-					n.connected = false
-					go n.reconnect()
-				}
-				n.lock.Unlock()
+		call := <-myDone
+		if call.Error != nil {
+			n.lock.Lock()
+			if n.connected {
+				n.endpoint.Close()
+				n.connected = false
+				go n.reconnect()
 			}
+			n.lock.Unlock()
+		}
 
-			if done != nil {
-				done <- call
-			}
+		if done != nil {
+			done <- call
 		}
+
 	}()
 
 	call := n.endpoint.Go(proc, msg, resp, myDone)