diff --git a/progress.go b/progress.go
index 9da3812..6e9bc86 100644
--- a/progress.go
+++ b/progress.go
@@ -354,10 +354,11 @@
 		}
 	}
 
+	err := cw.Flush(readRows - popCount)
 	wg.Wait()
 	s.rows = s.rows[:0]
 	s.pool = s.pool[:0]
-	return cw.Flush(readRows - popCount)
+	return err
 }
 
 func (s *pState) newTicker(done <-chan struct{}) chan time.Time {