(feed <-chan (*ChangeEntry), timeout time.Duration)
| 1313 | } |
| 1314 | |
| 1315 | func readNextFromFeed(feed <-chan (*ChangeEntry), timeout time.Duration) (*ChangeEntry, error) { |
| 1316 | |
| 1317 | select { |
| 1318 | case entry, ok := <-feed: |
| 1319 | if ok { |
| 1320 | return entry, nil |
| 1321 | } else { |
| 1322 | log.Printf("Non-entry error (%v): %v", ok, entry) |
| 1323 | return nil, errors.New("Non-entry returned on feed.") |
| 1324 | } |
| 1325 | case <-time.After(timeout): |
| 1326 | return nil, errors.New("Timeout waiting for entry") |
| 1327 | } |
| 1328 | |
| 1329 | } |
| 1330 | |
| 1331 | // Repro SG #2633 |
| 1332 | // |
no test coverage detected