Function TestSendEventUnblocksOnCancel

internal/llm/llm_test.go:423–443

TestSendEventUnblocksOnCancel pins sendEvent's anti-wedge invariant: once the parent context is cancelled, a send to an undrained channel must abort via the <-parent.Done() arm instead of blocking the stream goroutine forever. This is the only path exercising that arm. A regression to a plain `out <

(t *testing.T)

// Chat goroutine on Ctrl+C against a full buffer; the goroutine never returns and
// the deadline below fires.
func TestSendEventUnblocksOnCancel(t *testing.T) {
	out := make(chan Event) // unbuffered, no reader → the send blocks until cancel
	ctx, cancel := context.WithCancel(context.Background())

	done := make(chan bool, 1)
	go func() {
		done <- sendEvent(ctx, out, Event{Kind: EventContent, Content: "nobody is reading me"})
	}()

	// The send is wedged (no reader on out); cancelling must release it.
	cancel()

	select {
	case ok := <-done:
		if ok {
			t.Fatal("sendEvent returned true for a send nobody drained; it must report false after cancel")
		}
	case <-time.After(2 * time.Second):
		t.Fatal("sendEvent wedged on an undrained channel after cancel - the anti-wedge <-parent.Done() arm is missing")
	}
}

// TestChat401: maps to typed ErrUnauthorized.
func TestChat401(t *testing.T) {