(t *testing.T)
| 414 | } |
| 415 | |
| 416 | func TestWatcher_ClosedBeforeDial(t *testing.T) { |
| 417 | t.Parallel() |
| 418 | |
| 419 | ctx := testutil.Context(t, testutil.WaitShort) |
| 420 | logger := testutil.Logger(t) |
| 421 | h := newHarness(ctx, t, logger) |
| 422 | h.watcher.Close() |
| 423 | _, err := h.Dial(ctx, "wss://local.test/") |
| 424 | var sdkError *codersdk.Error |
| 425 | require.True(t, errors.As(err, &sdkError)) |
| 426 | require.Equal(t, http.StatusServiceUnavailable, sdkError.StatusCode()) |
| 427 | } |
| 428 | |
| 429 | func TestWatcher_ClosedAfterDial(t *testing.T) { |
| 430 | t.Parallel() |
nothing calls this directly
no test coverage detected