Method
Receiver
(receiver chan Database, receiverDone chan bool)
Source from the content-addressed store, hash-verified
| 217 | } |
| 218 | |
| 219 | func (m *DatabasesModule) Receiver(receiver chan Database, receiverDone chan bool) { |
| 220 | defer close(receiverDone) |
| 221 | for { |
| 222 | select { |
| 223 | case data := <-receiver: |
| 224 | m.Databases = append(m.Databases, data) |
| 225 | case <-receiverDone: |
| 226 | receiverDone <- true |
| 227 | return |
| 228 | } |
| 229 | } |
| 230 | } |
| 231 | |
| 232 | func (m *DatabasesModule) executeChecks(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Database) { |
| 233 | defer wg.Done() |
Tested by
no test coverage detected