Codebase list golang-github-vbauerster-mpb / 15685c9
consice code Vladimir Bauer 7 years ago
1 changed file(s) with 16 addition(s) and 20 deletion(s). Raw diff Collapse all Expand all
290290 }
291291 }
292292 }()
293 r := s.draw(tw)
294 var extendedLines int
293 frame := &bFrame{
294 rd: s.draw(tw),
295 toShutdown: s.toComplete && !s.completeFlushed,
296 removeOnComplete: s.removeOnComplete,
297 }
295298 if s.extender != nil {
296299 s.extender.Fill(s.bufE, tw, newStatistics(s))
297 extendedLines = countLines(s.bufE.Bytes())
298 r = io.MultiReader(r, s.bufE)
299 }
300 b.bFrameCh <- &bFrame{
301 rd: r,
302 extendedLines: extendedLines,
303 toShutdown: s.toComplete && !s.completeFlushed,
304 removeOnComplete: s.removeOnComplete,
305 }
300 frame.extendedLines = countLines(s.bufE.Bytes())
301 frame.rd = io.MultiReader(frame.rd, s.bufE)
302 }
303 b.bFrameCh <- frame
306304 s.completeFlushed = s.toComplete
307305 }:
308306 case <-b.done:
309307 s := b.cacheState
310 r := s.draw(tw)
311 var extendedLines int
308 frame := &bFrame{
309 rd: s.draw(tw),
310 }
312311 if s.extender != nil {
313312 s.extender.Fill(s.bufE, tw, newStatistics(s))
314 extendedLines = countLines(s.bufE.Bytes())
315 r = io.MultiReader(r, s.bufE)
316 }
317 b.bFrameCh <- &bFrame{
318 rd: r,
319 extendedLines: extendedLines,
320 }
313 frame.extendedLines = countLines(s.bufE.Bytes())
314 frame.rd = io.MultiReader(frame.rd, s.bufE)
315 }
316 b.bFrameCh <- frame
321317 }
322318 }
323319