~ecs/hq

78ab44cc28310b237b28a6e7385f6c6cda7c5c29 — Eyal Sawady 17 days ago 73e27a6
Fix send on closed channel
1 files changed, 4 insertions(+), 4 deletions(-)

M main.go
M main.go => main.go +4 -4
@@ 109,13 109,13 @@ func Exec(e Expr, ins []<-chan Datum, out chan Datum) error {
			}
			errs <- Exec(e.Multi.Out, inputs, out)
		}()
		err := <-errs
		for range e.Multi.Cmds {
			err := <-errs
			if err != nil {
				return err
			if e := <-errs; e != nil {
				err = e
			}
		}
		return <-errs
		return err
	}
	if len(e.Cmd) == 0 {
		close(out)