diff --git a/bar.go b/bar.go index bd440c1..f968f1f 100644 --- a/bar.go +++ b/bar.go @@ -65,8 +65,8 @@ type frame struct { reader io.Reader lines int - shutdown bool abort bool + complete bool } func newBar(container *Progress, bs *bState) (*Bar, func()) { @@ -335,8 +335,8 @@ b.frameCh <- &frame{ reader: reader, lines: lines + 1, - shutdown: s.completed && !s.completeFlushed, abort: s.aborted && !s.completeFlushed, + complete: s.completed && !s.completeFlushed, } s.completeFlushed = s.completed || s.aborted }() diff --git a/progress.go b/progress.go index 241b548..bb98589 100644 --- a/progress.go +++ b/progress.go @@ -314,7 +314,7 @@ } if frame.abort { s.barShutdownQueue = append(s.barShutdownQueue, b) - } else if frame.shutdown { + } else if frame.complete { // shutdown at next flush // this ensures no bar ends up with less than 100% rendered defer func() {