Method
Receiver
(receiver chan Endpoint, receiverDone chan bool)
Source from the content-addressed store, hash-verified
| 248 | } |
| 249 | |
| 250 | func (m *EndpointsModule) Receiver(receiver chan Endpoint, receiverDone chan bool) { |
| 251 | defer close(receiverDone) |
| 252 | for { |
| 253 | select { |
| 254 | case data := <-receiver: |
| 255 | m.Endpoints = append(m.Endpoints, data) |
| 256 | case <-receiverDone: |
| 257 | receiverDone <- true |
| 258 | return |
| 259 | } |
| 260 | } |
| 261 | } |
| 262 | |
| 263 | func (m *EndpointsModule) executeChecks(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint) { |
| 264 | defer wg.Done() |
Tested by
no test coverage detected