Function drainRunStream

pkg/runtime/compaction_model_integration_test.go:53–60

(t *testing.T, rt *LocalRuntime, sess *session.Session)

}

func drainRunStream(t *testing.T, rt *LocalRuntime, sess *session.Session) []Event {
	t.Helper()
	var events []Event
	for ev := range rt.RunStream(t.Context(), sess) {
		events = append(events, ev)
	}
	return events
}

// TestRunStream_GaugeUsesEffectiveContextLimit verifies end-to-end that the UI
// context gauge (TokenUsageEvent) reports the EFFECTIVE window — the primary