Function runOverflowSession

pkg/runtime/overflow_compaction_test.go:18–30

runOverflowSession drives a RunStream against a model that always returns a ContextOverflowError, returning the number of "started" compaction events observed and whether the runtime ultimately surfaced an ErrorEvent.

(t *testing.T, rt *LocalRuntime)

// ContextOverflowError, returning the number of "started" compaction events
// observed and whether the runtime ultimately surfaced an ErrorEvent.
func runOverflowSession(t *testing.T, rt *LocalRuntime) (compactions int, sawError bool) {
	t.Helper()
	sess := session.New(session.WithUserMessage("Hello"))
	for ev := range rt.RunStream(t.Context(), sess) {
		if e, ok := ev.(*SessionCompactionEvent); ok && e.Status == "started" {
			compactions++
		}
		if _, ok := ev.(*ErrorEvent); ok {
			sawError = true
		}
	}
	return compactions, sawError
}

// TestWithMaxOverflowCompactions_Zero verifies that passing 0 disables the
// compaction-retry path entirely: an overflow error surfaces immediately