diff --git a/progress.go b/progress.go index 378b9ca..178ad17 100644 --- a/progress.go +++ b/progress.go @@ -351,12 +351,15 @@ s.pool = append(s.pool, qb) drop = true } else if s.popCompleted && !b.bs.noPop { - if frame.shutdown > 1 { - popCount += usedRows - drop = true - } else { + switch frame.shutdown { + case 1: + b.priority = s.popPriority s.popPriority++ - b.priority = s.popPriority + drop = false + default: + if drop { + popCount += usedRows + } } } if drop {