Struct mockAgentIO

x/acpio/acp_conversation_test.go:20–34

mockAgentIO implements acpio.ChunkableAgentIO for testing. It provides a channel-based synchronization mechanism to test ACPConversation without relying on time.Sleep.

// It provides a channel-based synchronization mechanism to test ACPConversation
// without relying on time.Sleep.
type mockAgentIO struct {
	mu            sync.Mutex
	written       []byte
	screenContent string
	onChunkFn     func(chunk string)

	// Control behavior
	writeErr error
	// writeBlock is a channel that, if non-nil, will cause Write to block until closed.
	// This allows tests to control when the write completes.
	writeBlock chan struct{}
	// writeStarted is closed when Write begins (before blocking on writeBlock).
	// This allows tests to synchronize on the write starting.
	writeStarted chan struct{}
}

// mockEmitter implements screentracker.Emitter for testing.
type mockEmitter struct {