Sometimes messages misordered by device.

nanomsg · Oct 22, 2018 · 270ef90 · 270ef90
1 parent 2fbfc63
commit 270ef90
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/device.go b/device.go
@@ -60,7 +60,9 @@ func Device(s1 Socket, s2 Socket) error {
 	}
 
 	go forwarder(s1, s2)
-	go forwarder(s2, s1)
+	if s2 != s1 {
+		go forwarder(s2, s1)
+	}
 	return nil
 }