(_ *fasthttp.Request, _ *fasthttp.Response)
| 490 | } |
| 491 | |
| 492 | func (b *blockingErrTransport) Do(_ *fasthttp.Request, _ *fasthttp.Response) error { |
| 493 | b.calledOnce.Do(func() { close(b.called) }) |
| 494 | <-b.unblock |
| 495 | b.finishedOnce.Do(func() { close(b.finished) }) |
| 496 | return b.err |
| 497 | } |
| 498 | |
| 499 | func (b *blockingErrTransport) DoTimeout(req *fasthttp.Request, resp *fasthttp.Response, _ time.Duration) error { |
| 500 | return b.Do(req, resp) |
no test coverage detected