check each err
Vladimir Bauer
8 years ago
| 226 | 226 | for s.bHeap.Len() > 0 { |
| 227 | 227 | bar := heap.Pop(s.bHeap).(*Bar) |
| 228 | 228 | reader := <-bar.frameReaderCh |
| 229 | _, err = s.cw.ReadFrom(reader) | |
| 229 | if _, e := s.cw.ReadFrom(reader); e != nil { | |
| 230 | err = e | |
| 231 | } | |
| 230 | 232 | defer func() { |
| 231 | 233 | if frame, ok := reader.(*frameReader); ok && frame.toShutdown { |
| 232 | 234 | // shutdown at next flush, in other words decrement underlying WaitGroup |