From f8d9aac9b7c0a822972b7230edf25b7af287892a Mon Sep 17 00:00:00 2001 From: Sergey Matveev Date: Thu, 8 Jul 2021 13:07:06 +0300 Subject: [PATCH] Wait for goroutine completion and error logging when tossing --- src/toss.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/toss.go b/src/toss.go index 69ad455..e5e3487 100644 --- a/src/toss.go +++ b/src/toss.go @@ -820,7 +820,7 @@ func jobProcess( ) if err != nil { pipeW.CloseWithError(err) - go func() { <-errs }() + <-errs return err } pipeW.Close() @@ -955,7 +955,7 @@ func (ctx *Ctx) Toss( if err != nil { isBad = true fd.Close() - go func() { <-errs }() + <-errs continue } if err = <-errs; err == JobRepeatProcess { -- 2.44.0