diff --git a/cmd/exec/exec.go b/cmd/exec/exec.go index 5c794998..375a8317 100644 --- a/cmd/exec/exec.go +++ b/cmd/exec/exec.go @@ -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)