diff --git a/progress.go b/progress.go index 1022209..3a1ee56 100644 --- a/progress.go +++ b/progress.go @@ -227,7 +227,9 @@ for s.bHeap.Len() > 0 { bar := heap.Pop(s.bHeap).(*Bar) reader := <-bar.frameReaderCh - _, err = s.cw.ReadFrom(reader) + if _, e := s.cw.ReadFrom(reader); e != nil { + err = e + } defer func() { if frame, ok := reader.(*frameReader); ok && frame.toShutdown { // shutdown at next flush, in other words decrement underlying WaitGroup