minor: if local var
Vladimir Bauer
3 years ago
| 292 | 292 | b := heap.Pop(&s.bHeap).(*Bar) |
| 293 | 293 | frame := <-b.frameCh |
| 294 | 294 | for i := len(frame.rows) - 1; i >= 0; i-- { |
| 295 | if len(rows) < height { | |
| 296 | rows = append(rows, frame.rows[i]) | |
| 295 | if row := frame.rows[i]; len(rows) < height { | |
| 296 | rows = append(rows, row) | |
| 297 | 297 | usedRows++ |
| 298 | 298 | } else { |
| 299 | 299 | wg.Add(1) |
| 300 | go func(discardRow io.Reader) { | |
| 301 | _, _ = io.Copy(io.Discard, discardRow) | |
| 300 | go func() { | |
| 301 | _, _ = io.Copy(io.Discard, row) | |
| 302 | 302 | wg.Done() |
| 303 | }(frame.rows[i]) | |
| 303 | }() | |
| 304 | 304 | } |
| 305 | 305 | } |
| 306 | 306 | if frame.shutdown != 0 { |