(breaker *Breaker)
| 353 | } |
| 354 | |
| 355 | func newRequestor(breaker *Breaker) *requestor { |
| 356 | return &requestor{ |
| 357 | breaker: breaker, |
| 358 | acceptedCh: make(chan bool), |
| 359 | barrierCh: make(chan struct{}), |
| 360 | } |
| 361 | } |
| 362 | |
| 363 | // request is the same as requestWithContext but with a default context. |
| 364 | func (r *requestor) request() { |
no outgoing calls
no test coverage detected