Method SubmitMessage

test/ui_runtime_parity_test.go:561–572

(ctx context.Context, userInput string, state *agent.AgentState, sessionID ...string)

type delayedSubmitEngine struct{}

func (e *delayedSubmitEngine) SubmitMessage(ctx context.Context, userInput string, state *agent.AgentState, sessionID ...string) <-chan agent.StreamEvent {
	out := make(chan agent.StreamEvent)
	go func() {
		defer close(out)
		select {
		case <-time.After(350 * time.Millisecond):
			out <- agent.NewStreamEvent("done", "", nil)
		case <-ctx.Done():
		}
	}()
	return out
}

type cancelAwareSubmitEngine struct{}