Fix unblocking exec error
This commit is contained in:
+7
-1
@@ -91,7 +91,13 @@ func Handle(url string) (streamer.Producer, error) {
|
|||||||
chErr := make(chan error)
|
chErr := make(chan error)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
chErr <- cmd.Wait()
|
err := cmd.Wait()
|
||||||
|
// unblocking write to channel
|
||||||
|
select {
|
||||||
|
case chErr <- err:
|
||||||
|
default:
|
||||||
|
log.Trace().Str("url", url).Msg("[exec] close")
|
||||||
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
select {
|
select {
|
||||||
|
|||||||
Reference in New Issue
Block a user