()
| 149 | } |
| 150 | |
| 151 | func (gi *githubImporter) getEventHandleMsgs() ImportEvent { |
| 152 | for { |
| 153 | // read event from import mediator |
| 154 | event := gi.mediator.NextImportEvent() |
| 155 | // consume (and use) all rate limiting events |
| 156 | if e, ok := event.(RateLimitingEvent); ok { |
| 157 | gi.out <- core.NewImportRateLimiting(e.msg) |
| 158 | continue |
| 159 | } |
| 160 | return event |
| 161 | } |
| 162 | } |
| 163 | |
| 164 | func (gi *githubImporter) commit(b *cache.BugCache, out chan<- core.ImportResult) error { |
| 165 | if b == nil { |
no test coverage detected