Struct ACPConversation

x/acpio/acp_conversation.go:29–43

ACPConversation tracks conversations with ACP-based agents. Unlike PTY-based Conversation, ACP has blocking writes where the response is complete when Write() returns.

// Unlike PTY-based Conversation, ACP has blocking writes where the
// response is complete when Write() returns.
type ACPConversation struct {
	mu                sync.Mutex
	ctx               context.Context
	cancel            context.CancelFunc
	agentIO           ChunkableAgentIO
	messages          []st.ConversationMessage
	nextID            int           // monotonically increasing message ID
	prompting         bool          // true while agent is processing
	chunkReceived     chan struct{} // signals that handleChunk has accumulated a chunk
	streamingResponse strings.Builder
	logger            *slog.Logger
	emitter           st.Emitter
	initialPrompt     []st.MessagePart
	clock             quartz.Clock
}

// noopEmitter is a no-op implementation of Emitter for when no emitter is provided.
type noopEmitter struct{}