return Flush err
Vladimir Bauer
7 years ago
| 219 | 219 | } |
| 220 | 220 | heap.Push(s.bHeap, bar) |
| 221 | 221 | }() |
| 222 | _, err = s.cw.ReadFrom(frameReader) | |
| 222 | s.cw.ReadFrom(frameReader) | |
| 223 | 223 | lineCount += frameReader.extendedLines |
| 224 | 224 | } |
| 225 | ||
| 226 | err = s.cw.Flush(lineCount) | |
| 227 | 225 | |
| 228 | 226 | for i := len(s.shutdownPending) - 1; i >= 0; i-- { |
| 229 | 227 | close(s.shutdownPending[i].shutdown) |
| 230 | 228 | s.shutdownPending = s.shutdownPending[:i] |
| 231 | 229 | } |
| 232 | return | |
| 230 | ||
| 231 | return s.cw.Flush(lineCount) | |
| 233 | 232 | } |
| 234 | 233 | |
| 235 | 234 | func syncWidth(matrix map[int][]chan int) { |