Fix unblocking exec waiter

2023-01-13 18:00:48 +03:00
parent 6151593c08
commit d12775a2d7
1 changed files with 7 additions and 2 deletions
@@ -34,8 +34,13 @@ func Init() {
 			return false
 		}

-		waiter <- conn
-		return true
+		// unblocking write to channel
+		select {
+		case waiter <- conn:
+			return true
+		default:
+			return false
+		}
 	})

 	streams.HandleFunc("exec", Handle)