Codebase list golang-github-vbauerster-mpb / b9b2467
Remove flushed ch Vladimir Bauer 8 years ago
2 changed file(s) with 2 addition(s) and 6 deletion(s). Raw diff Collapse all Expand all
+1
-3
bar.go less more
276276 }
277277 }
278278
279 func (b *Bar) render(tw int, flushed chan struct{}, prependWs, appendWs *widthSync) <-chan []byte {
279 func (b *Bar) render(tw int, prependWs, appendWs *widthSync) <-chan []byte {
280280 ch := make(chan []byte)
281281
282282 go func() {
291291 select {
292292 case b.ops <- func(s *state) {
293293 if s.completed {
294 fmt.Fprintln(os.Stderr, "bar completed")
295 // <-flushed
296294 b.Complete()
297295 }
298296 result <- *s
+1
-3
progress.go less more
213213
214214 tw, _, _ := cwriter.GetTermSize()
215215
216 flushed := make(chan struct{})
217216 sequence := make([]<-chan []byte, numBars)
218217 for i, b := range conf.bars {
219 sequence[i] = b.render(tw, flushed, prependWs, appendWs)
218 sequence[i] = b.render(tw, prependWs, appendWs)
220219 }
221220
222221 for buf := range fanIn(sequence...) {
228227 }
229228
230229 conf.cw.Flush()
231 close(flushed)
232230 case <-conf.cancel:
233231 conf.ticker.Stop()
234232 conf.cancel = nil