()
| 725 | } |
| 726 | |
| 727 | func (a *testAcquiree) requireBlocked() { |
| 728 | select { |
| 729 | case <-a.ec: |
| 730 | a.t.Fatal("AcquireJob should block") |
| 731 | default: |
| 732 | // OK |
| 733 | } |
| 734 | } |
| 735 | |
| 736 | func (a *testAcquiree) requireCanceled(ctx context.Context) { |
| 737 | select { |
no test coverage detected