wait after flush
Vladimir Bauer
3 years ago
1 changed file(s) with
2 addition(s)
and
1 deletion(s)
.
Raw diff
Collapse all
Expand all
+2
-1
progress.go
less
more
353
353
}
354
354
}
355
355
356
err := cw.Flush(readRows - popCount)
356
357
wg.Wait()
357
358
s.rows = s.rows[:0]
358
359
s.pool = s.pool[:0]
359
return cw.Flush(readRows - popCount)
360
return err
360
361
}
361
362
362
363
func (s *pState) newTicker(done <-chan struct{}) chan time.Time {