(ctx context.Context)
| 734 | } |
| 735 | |
| 736 | func (a *testAcquiree) requireCanceled(ctx context.Context) { |
| 737 | select { |
| 738 | case err := <-a.ec: |
| 739 | require.ErrorIs(a.t, err, context.Canceled) |
| 740 | case <-ctx.Done(): |
| 741 | a.t.Fatal("timed out waiting for AcquireJob") |
| 742 | } |
| 743 | select { |
| 744 | case job := <-a.jc: |
| 745 | require.Equal(a.t, uuid.Nil, job.ID) |
| 746 | case <-ctx.Done(): |
| 747 | a.t.Fatal("timed out waiting for AcquireJob") |
| 748 | } |
| 749 | } |
no test coverage detected